diff --git a/ingestion/src/main/java/feast/ingestion/transform/FeatureEnums.java b/ingestion/src/main/java/feast/ingestion/transform/FeatureEnums.java deleted file mode 100644 index 77985082cd0..00000000000 --- a/ingestion/src/main/java/feast/ingestion/transform/FeatureEnums.java +++ /dev/null @@ -1,15 +0,0 @@ -package feast.ingestion.transform; - -public class FeatureEnums { - public enum InputSource { - FILE, - BIGQUERY, - PUBSUB, - KAFKA - } - - public enum FileFormat { - CSV, - JSON - } -} \ No newline at end of file diff --git a/ingestion/src/main/java/feast/ingestion/util/JsonUtil.java b/ingestion/src/main/java/feast/ingestion/util/JsonUtil.java index b142c013f7d..d32a79d1c42 100644 --- a/ingestion/src/main/java/feast/ingestion/util/JsonUtil.java +++ b/ingestion/src/main/java/feast/ingestion/util/JsonUtil.java @@ -1,3 +1,20 @@ +/* + * Copyright 2019 The Feast Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package feast.ingestion.util; import com.google.gson.Gson; diff --git a/ingestion/src/main/java/feast/source/FeatureSource.java b/ingestion/src/main/java/feast/source/FeatureSource.java index 4514b2de37d..e4c0590b32b 100644 --- a/ingestion/src/main/java/feast/source/FeatureSource.java +++ b/ingestion/src/main/java/feast/source/FeatureSource.java @@ -1,3 +1,20 @@ +/* + * Copyright 2019 The Feast Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package feast.source; import feast.types.FeatureRowProto.FeatureRow; diff --git a/ingestion/src/main/java/feast/source/FeatureSourceFactory.java b/ingestion/src/main/java/feast/source/FeatureSourceFactory.java index 1de49cf3429..fc4d64418cd 100644 --- a/ingestion/src/main/java/feast/source/FeatureSourceFactory.java +++ b/ingestion/src/main/java/feast/source/FeatureSourceFactory.java @@ -1,3 +1,20 @@ +/* + * Copyright 2019 The Feast Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package feast.source; import feast.specs.ImportSpecProto.ImportSpec; diff --git a/ingestion/src/main/java/feast/source/FeatureSourceFactoryService.java b/ingestion/src/main/java/feast/source/FeatureSourceFactoryService.java index e4dd994dcc0..18917cb1dac 100644 --- a/ingestion/src/main/java/feast/source/FeatureSourceFactoryService.java +++ b/ingestion/src/main/java/feast/source/FeatureSourceFactoryService.java @@ -1,3 +1,20 @@ +/* + * Copyright 2019 The Feast Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package feast.source; import avro.shaded.com.google.common.collect.Lists; diff --git a/ingestion/src/main/java/feast/source/bigquery/BigQueryFeatureSource.java b/ingestion/src/main/java/feast/source/bigquery/BigQueryFeatureSource.java index b4b3973b5c4..9ce7f965f2c 100644 --- a/ingestion/src/main/java/feast/source/bigquery/BigQueryFeatureSource.java +++ b/ingestion/src/main/java/feast/source/bigquery/BigQueryFeatureSource.java @@ -1,3 +1,20 @@ +/* + * Copyright 2019 The Feast Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package feast.source.bigquery; import static com.google.common.base.Preconditions.checkArgument; diff --git a/ingestion/src/test/java/feast/ingestion/ImportJobCSVTest.java b/ingestion/src/test/java/feast/ingestion/ImportJobCSVTest.java index 4a2fab2c6d0..c6adf7dd22d 100644 --- a/ingestion/src/test/java/feast/ingestion/ImportJobCSVTest.java +++ b/ingestion/src/test/java/feast/ingestion/ImportJobCSVTest.java @@ -282,9 +282,8 @@ public void testImportWithoutWarehouseStore() throws IOException { ImportSpec importSpec = ProtoUtil.decodeProtoYaml( "---\n" - + "type: file\n" + + "type: file.csv\n" + "options:\n" - + " format: csv\n" + " # path: to be overwritten in tests\n" + "entities:\n" + " - testEntity\n" diff --git a/ingestion/src/test/java/feast/ingestion/model/SpecsTest.java b/ingestion/src/test/java/feast/ingestion/model/SpecsTest.java index 17aceba18ea..d0707310548 100644 --- a/ingestion/src/test/java/feast/ingestion/model/SpecsTest.java +++ b/ingestion/src/test/java/feast/ingestion/model/SpecsTest.java @@ -1,3 +1,20 @@ +/* + * Copyright 2019 The Feast Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package feast.ingestion.model; import static junit.framework.TestCase.assertTrue; diff --git a/ingestion/src/test/java/feast/ingestion/service/MockSpecService.java b/ingestion/src/test/java/feast/ingestion/service/MockSpecService.java index 626545e115f..54e70b39a6d 100644 --- a/ingestion/src/test/java/feast/ingestion/service/MockSpecService.java +++ b/ingestion/src/test/java/feast/ingestion/service/MockSpecService.java @@ -1,3 +1,20 @@ +/* + * Copyright 2019 The Feast Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package feast.ingestion.service; import com.google.common.collect.Maps; diff --git a/ingestion/src/test/java/feast/ingestion/transform/SplitOutputByStoreTest.java b/ingestion/src/test/java/feast/ingestion/transform/SplitOutputByStoreTest.java index 09e8ef5434b..7758a774899 100644 --- a/ingestion/src/test/java/feast/ingestion/transform/SplitOutputByStoreTest.java +++ b/ingestion/src/test/java/feast/ingestion/transform/SplitOutputByStoreTest.java @@ -1,3 +1,20 @@ +/* + * Copyright 2019 The Feast Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package feast.ingestion.transform; import static junit.framework.TestCase.assertNull;