http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/HiveSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/HiveSourceTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/HiveSourceTest.java index 9ca7d4e..9d6bd32 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/HiveSourceTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/HiveSourceTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive; +package org.apache.gobblin.data.management.conversion.hive; import java.util.List; import java.util.Map; @@ -32,15 +32,15 @@ import com.google.common.collect.ImmutableList; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.ConversionHiveTestUtils; -import gobblin.data.management.conversion.hive.source.HiveSource; -import gobblin.data.management.conversion.hive.source.HiveWorkUnit; -import gobblin.data.management.conversion.hive.watermarker.PartitionLevelWatermarker; -import gobblin.data.management.conversion.hive.watermarker.TableLevelWatermarker; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.ConversionHiveTestUtils; +import org.apache.gobblin.data.management.conversion.hive.source.HiveSource; +import org.apache.gobblin.data.management.conversion.hive.source.HiveWorkUnit; +import org.apache.gobblin.data.management.conversion.hive.watermarker.PartitionLevelWatermarker; +import org.apache.gobblin.data.management.conversion.hive.watermarker.TableLevelWatermarker; +import org.apache.gobblin.source.workunit.WorkUnit; @Test(groups = { "gobblin.data.management.conversion" })
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/LocalHiveMetastoreTestUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/LocalHiveMetastoreTestUtils.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/LocalHiveMetastoreTestUtils.java index b8e5bb1..32c6af8 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/LocalHiveMetastoreTestUtils.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/LocalHiveMetastoreTestUtils.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive; +package org.apache.gobblin.data.management.conversion.hive; import java.io.File; import java.io.IOException; @@ -42,8 +42,8 @@ import org.apache.thrift.TException; import com.google.common.base.Optional; import com.google.common.collect.ImmutableMap; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.hive.avro.HiveAvroSerDeManager; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.hive.avro.HiveAvroSerDeManager; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java index 7381ed3..6732b48 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.conversion.hive.converter; +package org.apache.gobblin.data.management.conversion.hive.converter; import java.io.IOException; import java.util.List; @@ -35,15 +35,15 @@ import com.google.common.collect.Lists; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.ConversionHiveTestUtils; -import gobblin.data.management.conversion.hive.LocalHiveMetastoreTestUtils; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDatasetTest; -import gobblin.data.management.conversion.hive.entities.QueryBasedHiveConversionEntity; -import gobblin.data.management.conversion.hive.entities.SchemaAwareHivePartition; -import gobblin.data.management.conversion.hive.entities.SchemaAwareHiveTable; -import gobblin.data.management.copy.hive.WhitelistBlacklist; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.ConversionHiveTestUtils; +import org.apache.gobblin.data.management.conversion.hive.LocalHiveMetastoreTestUtils; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDatasetTest; +import org.apache.gobblin.data.management.conversion.hive.entities.QueryBasedHiveConversionEntity; +import org.apache.gobblin.data.management.conversion.hive.entities.SchemaAwareHivePartition; +import org.apache.gobblin.data.management.conversion.hive.entities.SchemaAwareHiveTable; +import org.apache.gobblin.data.management.copy.hive.WhitelistBlacklist; @Test(groups = { "gobblin.data.management.conversion" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveSchemaEvolutionTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveSchemaEvolutionTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveSchemaEvolutionTest.java index abbbc57..36edcd9 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveSchemaEvolutionTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveSchemaEvolutionTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive.converter; +package org.apache.gobblin.data.management.conversion.hive.converter; import java.io.IOException; import java.util.ArrayList; @@ -37,9 +37,9 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.data.management.ConversionHiveTestUtils; -import gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator; -import gobblin.util.AvroFlattener; +import org.apache.gobblin.data.management.ConversionHiveTestUtils; +import org.apache.gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator; +import org.apache.gobblin.util.AvroFlattener; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetTest.java index 3fdf97e..51a390d 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive.dataset; +package org.apache.gobblin.data.management.conversion.hive.dataset; import java.io.InputStream; import java.util.Properties; @@ -32,9 +32,9 @@ import com.google.common.collect.ImmutableSet; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.util.ConfigUtils; @Test(groups = { "gobblin.data.management.conversion" }) public class ConvertibleHiveDatasetTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProviderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProviderTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProviderTest.java index 92c0567..ee954f4 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProviderTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProviderTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive.provider; +package org.apache.gobblin.data.management.conversion.hive.provider; import org.apache.hadoop.hive.metastore.api.StorageDescriptor; import org.apache.hadoop.hive.ql.metadata.Partition; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/util/HiveAvroORCQueryGeneratorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/util/HiveAvroORCQueryGeneratorTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/util/HiveAvroORCQueryGeneratorTest.java index e17dc98..410c3bd 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/util/HiveAvroORCQueryGeneratorTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/util/HiveAvroORCQueryGeneratorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.conversion.hive.util; +package org.apache.gobblin.data.management.conversion.hive.util; import java.io.IOException; import java.util.Collections; @@ -32,9 +32,9 @@ import com.google.common.base.Optional; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Lists; -import gobblin.data.management.ConversionHiveTestUtils; -import gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator; -import gobblin.util.AvroFlattener; +import org.apache.gobblin.data.management.ConversionHiveTestUtils; +import org.apache.gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator; +import org.apache.gobblin.util.AvroFlattener; @Test(groups = { "gobblin.data.management.conversion" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/PartitionLevelWatermarkerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/PartitionLevelWatermarkerTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/PartitionLevelWatermarkerTest.java index e78381a..281ee62 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/PartitionLevelWatermarkerTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/PartitionLevelWatermarkerTest.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive.watermarker; +package org.apache.gobblin.data.management.conversion.hive.watermarker; import com.google.common.base.Optional; import com.google.common.io.Files; -import gobblin.data.management.conversion.hive.LocalHiveMetastoreTestUtils; +import org.apache.gobblin.data.management.conversion.hive.LocalHiveMetastoreTestUtils; import java.io.File; import java.util.Collections; import java.util.Comparator; @@ -38,14 +38,14 @@ import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.conversion.hive.converter.AbstractAvroToOrcConverter; -import gobblin.data.management.conversion.hive.source.HiveSource; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.conversion.hive.converter.AbstractAvroToOrcConverter; +import org.apache.gobblin.data.management.conversion.hive.source.HiveSource; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.source.workunit.WorkUnit; /* http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/TableLevelWatermarkerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/TableLevelWatermarkerTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/TableLevelWatermarkerTest.java index 4422340..3c0a062 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/TableLevelWatermarkerTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/watermarker/TableLevelWatermarkerTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive.watermarker; +package org.apache.gobblin.data.management.conversion.hive.watermarker; import java.util.List; @@ -28,11 +28,11 @@ import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.extract.LongWatermark; @Test(groups = { "gobblin.data.management.conversion" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitListTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitListTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitListTest.java index 5a9d2f3..0dc9bc3 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitListTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitListTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.io.IOException; @@ -31,9 +31,9 @@ import com.google.common.base.Splitter; import com.google.common.collect.Maps; import com.google.common.collect.Lists; -import gobblin.data.management.dataset.DummyDataset; -import gobblin.data.management.partition.FileSet; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.data.management.dataset.DummyDataset; +import org.apache.gobblin.data.management.partition.FileSet; +import org.apache.gobblin.source.workunit.WorkUnit; public class ConcurrentBoundedWorkUnitListTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourcePrioritizationTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourcePrioritizationTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourcePrioritizationTest.java index 73da299..2b55bd4 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourcePrioritizationTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourcePrioritizationTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.io.IOException; import java.util.Collection; @@ -34,16 +34,16 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.data.management.copy.prioritization.FileSetComparator; -import gobblin.data.management.dataset.DatasetUtils; -import gobblin.data.management.partition.FileSet; -import gobblin.data.management.partition.FileSetResourceEstimator; -import gobblin.dataset.Dataset; -import gobblin.dataset.IterableDatasetFinder; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.JobLauncherUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.data.management.copy.prioritization.FileSetComparator; +import org.apache.gobblin.data.management.dataset.DatasetUtils; +import org.apache.gobblin.data.management.partition.FileSet; +import org.apache.gobblin.data.management.partition.FileSetResourceEstimator; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.IterableDatasetFinder; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.JobLauncherUtils; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourceTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourceTest.java index 773157a..d9e5368 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourceTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopySourceTest.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.util.List; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.data.management.dataset.DatasetUtils; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.JobLauncherUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.data.management.dataset.DatasetUtils; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.JobLauncherUtils; public class CopySourceTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableDatasetMetadataTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableDatasetMetadataTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableDatasetMetadataTest.java index 776a227..e8de8d3 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableDatasetMetadataTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableDatasetMetadataTest.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; import org.apache.hadoop.fs.Path; import org.testng.Assert; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileTest.java index c31fbc2..c523c35 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.io.IOException; import java.net.URI; @@ -35,8 +35,8 @@ import com.google.common.collect.ImmutableList; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.PathUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.PathUtils; public class CopyableFileTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileUtils.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileUtils.java index bcb8570..f0442d9 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileUtils.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/CopyableFileUtils.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/PreserveAttributesTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/PreserveAttributesTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/PreserveAttributesTest.java index d8e7110..6593e46 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/PreserveAttributesTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/PreserveAttributesTest.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; -import gobblin.data.management.copy.PreserveAttributes.Option; +import org.apache.gobblin.data.management.copy.PreserveAttributes.Option; import java.util.Map; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ReadyCopyableFileFilterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ReadyCopyableFileFilterTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ReadyCopyableFileFilterTest.java index 0ebca5f..f262a6d 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ReadyCopyableFileFilterTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/ReadyCopyableFileFilterTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.util.Collection; import java.util.List; @@ -26,7 +26,7 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.util.PathUtils; +import org.apache.gobblin.util.PathUtils; @Test(groups = {"gobblin.data.management.copy"}) public class ReadyCopyableFileFilterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/RecursiveCopyableDatasetTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/RecursiveCopyableDatasetTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/RecursiveCopyableDatasetTest.java index 5971708..14011d2 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/RecursiveCopyableDatasetTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/RecursiveCopyableDatasetTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.io.IOException; import java.util.Collection; @@ -37,10 +37,10 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.collect.Sets; -import gobblin.commit.CommitStep; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.copy.entities.CommitStepCopyEntity; -import gobblin.util.commit.DeleteFileCommitStep; +import org.apache.gobblin.commit.CommitStep; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.copy.entities.CommitStepCopyEntity; +import org.apache.gobblin.util.commit.DeleteFileCommitStep; import avro.shaded.com.google.common.base.Predicate; import avro.shaded.com.google.common.collect.Iterables; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDataset.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDataset.java index bca0030..5b5ddf7 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDataset.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.io.IOException; import java.util.Collection; @@ -29,7 +29,7 @@ import org.apache.hadoop.fs.permission.FsPermission; import com.google.common.collect.Lists; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.dataset.FileSystemDataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDatasetFinder.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDatasetFinder.java index d514069..2c98fdb 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDatasetFinder.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyableDatasetFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.io.IOException; import java.util.List; @@ -26,7 +26,7 @@ import org.apache.hadoop.fs.Path; import com.google.common.collect.Lists; -import gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.dataset.DatasetsFinder; public class TestCopyableDatasetFinder implements DatasetsFinder<CopyableDataset> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDatasedFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDatasedFinder.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDatasedFinder.java index b8c7bd0..2cfd77d 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDatasedFinder.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDatasedFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import java.io.IOException; import java.util.List; @@ -26,7 +26,7 @@ import org.apache.hadoop.fs.Path; import com.google.common.collect.Lists; -import gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.dataset.DatasetsFinder; public class TestCopyablePartitionableDatasedFinder implements DatasetsFinder<CopyableDataset> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDataset.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDataset.java index c51fb9e..c1bd27e 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDataset.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TestCopyablePartitionableDataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import org.apache.hadoop.fs.FileStatus; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TimestampBasedCopyableDatasetTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TimestampBasedCopyableDatasetTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TimestampBasedCopyableDatasetTest.java index 72d9de5..c230148 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TimestampBasedCopyableDatasetTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/TimestampBasedCopyableDatasetTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy; +package org.apache.gobblin.data.management.copy; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; @@ -41,14 +41,14 @@ import org.testng.Assert; import org.testng.annotations.BeforeTest; import org.testng.annotations.Test; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.policy.VersionSelectionPolicy; -import gobblin.data.management.version.DatasetVersion; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; -import gobblin.data.management.version.finder.VersionFinder; -import gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.policy.VersionSelectionPolicy; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.version.finder.VersionFinder; +import org.apache.gobblin.dataset.Dataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/DecryptConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/DecryptConverterTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/DecryptConverterTest.java index b8de243..ec83771 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/DecryptConverterTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/DecryptConverterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.converter; +package org.apache.gobblin.data.management.copy.converter; import java.io.File; import java.io.IOException; @@ -36,13 +36,13 @@ import com.google.common.base.Charsets; import com.google.common.collect.Iterables; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.crypto.EncryptionConfigParser; -import gobblin.data.management.copy.CopyableFileUtils; -import gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.crypto.EncryptionConfigParser; +import org.apache.gobblin.data.management.copy.CopyableFileUtils; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/UnGzipConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/UnGzipConverterTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/UnGzipConverterTest.java index 124a1d7..9f1f8c7 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/UnGzipConverterTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/converter/UnGzipConverterTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.converter; +package org.apache.gobblin.data.management.copy.converter; import java.io.IOException; import java.io.InputStream; @@ -36,10 +36,10 @@ import com.google.common.collect.Iterables; import joptsimple.internal.Strings; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.data.management.copy.CopyableFileUtils; -import gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.data.management.copy.CopyableFileUtils; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; public class UnGzipConverterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/extractor/InputStreamExtractorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/extractor/InputStreamExtractorTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/extractor/InputStreamExtractorTest.java index d06f562..c2ead06 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/extractor/InputStreamExtractorTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/extractor/InputStreamExtractorTest.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.extractor; +package org.apache.gobblin.data.management.copy.extractor; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopyContext; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.FileAwareInputStream; -import gobblin.data.management.copy.PreserveAttributes; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopyContext; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.data.management.copy.PreserveAttributes; import java.io.IOException; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveCopyEntityHelperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveCopyEntityHelperTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveCopyEntityHelperTest.java index 98546fb..2f252cc 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveCopyEntityHelperTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveCopyEntityHelperTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.hive; +package org.apache.gobblin.data.management.copy.hive; import java.io.IOException; import java.util.ArrayList; @@ -39,12 +39,12 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.configuration.State; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.entities.PostPublishStep; -import gobblin.data.management.copy.hive.HiveCopyEntityHelper.DeregisterFileDeleteMethod; -import gobblin.hive.HiveRegProps; -import gobblin.metrics.event.MultiTimingEvent; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.entities.PostPublishStep; +import org.apache.gobblin.data.management.copy.hive.HiveCopyEntityHelper.DeregisterFileDeleteMethod; +import org.apache.gobblin.hive.HiveRegProps; +import org.apache.gobblin.metrics.event.MultiTimingEvent; public class HiveCopyEntityHelperTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinderTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinderTest.java index 1f6d214..70ef3d1 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinderTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.hive; +package org.apache.gobblin.data.management.copy.hive; import java.io.IOException; import java.util.List; @@ -36,8 +36,8 @@ import com.google.common.collect.SetMultimap; import com.google.common.collect.Sets; import com.typesafe.config.Config; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.util.AutoReturnableObject; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.util.AutoReturnableObject; public class HiveDatasetFinderTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetTest.java index 7b06722..ba0ad49 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.hive; +package org.apache.gobblin.data.management.copy.hive; import java.io.IOException; @@ -25,7 +25,7 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.retention.version.HiveDatasetVersionCleaner; +import org.apache.gobblin.data.management.retention.version.HiveDatasetVersionCleaner; public class HiveDatasetTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveTargetPathHelperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveTargetPathHelperTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveTargetPathHelperTest.java index 796a202..f891685 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveTargetPathHelperTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/HiveTargetPathHelperTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.hive; +package org.apache.gobblin.data.management.copy.hive; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklistTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklistTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklistTest.java index 79995cf..564cdf2 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklistTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklistTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.hive; +package org.apache.gobblin.data.management.copy.hive; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/filter/LookbackPartitionFilterGeneratorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/filter/LookbackPartitionFilterGeneratorTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/filter/LookbackPartitionFilterGeneratorTest.java index 07ba9b1..f354cd8 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/filter/LookbackPartitionFilterGeneratorTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/hive/filter/LookbackPartitionFilterGeneratorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.hive.filter; +package org.apache.gobblin.data.management.copy.hive.filter; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/predicates/RegistrationTimeSkipPredicateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/predicates/RegistrationTimeSkipPredicateTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/predicates/RegistrationTimeSkipPredicateTest.java index 99e93d4..6df9733 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/predicates/RegistrationTimeSkipPredicateTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/predicates/RegistrationTimeSkipPredicateTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.predicates; +package org.apache.gobblin.data.management.copy.predicates; import java.util.Map; @@ -31,11 +31,11 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.common.collect.Maps; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopyContext; -import gobblin.data.management.copy.hive.HiveCopyEntityHelper; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.HivePartitionFileSet; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopyContext; +import org.apache.gobblin.data.management.copy.hive.HiveCopyEntityHelper; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.HivePartitionFileSet; public class RegistrationTimeSkipPredicateTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisherTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisherTest.java index 231e7ea..498b244 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisherTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisherTest.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.publisher; - -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopySource; -import gobblin.data.management.copy.CopyableDataset; -import gobblin.data.management.copy.CopyableDatasetMetadata; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.PreserveAttributes; -import gobblin.data.management.copy.TestCopyableDataset; -import gobblin.util.PathUtils; +package org.apache.gobblin.data.management.copy.publisher; + +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopySource; +import org.apache.gobblin.data.management.copy.CopyableDataset; +import org.apache.gobblin.data.management.copy.CopyableDatasetMetadata; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.PreserveAttributes; +import org.apache.gobblin.data.management.copy.TestCopyableDataset; +import org.apache.gobblin.util.PathUtils; import java.io.IOException; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/DeletingCopyDataPublisherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/DeletingCopyDataPublisherTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/DeletingCopyDataPublisherTest.java index 33f2dcf..3b99f9a 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/DeletingCopyDataPublisherTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/publisher/DeletingCopyDataPublisherTest.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.publisher; - -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.configuration.WorkUnitState.WorkingState; -import gobblin.data.management.copy.CopySource; -import gobblin.data.management.copy.CopyableDataset; -import gobblin.data.management.copy.CopyableDatasetMetadata; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.CopyableFileUtils; -import gobblin.data.management.copy.TestCopyableDataset; +package org.apache.gobblin.data.management.copy.publisher; + +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState.WorkingState; +import org.apache.gobblin.data.management.copy.CopySource; +import org.apache.gobblin.data.management.copy.CopyableDataset; +import org.apache.gobblin.data.management.copy.CopyableDatasetMetadata; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.CopyableFileUtils; +import org.apache.gobblin.data.management.copy.TestCopyableDataset; import java.io.File; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelperTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelperTest.java index 47028df..c825928 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelperTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelperTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.recovery; +package org.apache.gobblin.data.management.copy.recovery; import java.io.File; import java.io.FileInputStream; @@ -36,13 +36,13 @@ import com.google.common.base.Optional; import com.google.common.base.Predicates; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopySource; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.PreserveAttributes; -import gobblin.util.guid.Guid; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopySource; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.PreserveAttributes; +import org.apache.gobblin.util.guid.Guid; public class RecoveryHelperTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsFinderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsFinderTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsFinderTest.java index 634e34a..f8ea887 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsFinderTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsFinderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.replication; +package org.apache.gobblin.data.management.copy.replication; import com.google.common.base.Optional; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsTest.java index c062391..1965a41 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.replication; +package org.apache.gobblin.data.management.copy.replication; import java.net.URI; import java.util.Collection; @@ -32,18 +32,18 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.common.collect.Sets; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.PreserveAttributes; -import gobblin.data.management.copy.entities.PostPublishStep; -import gobblin.data.management.copy.entities.PrePublishStep; -import gobblin.source.extractor.ComparableWatermark; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.util.FileListUtils; -import gobblin.util.PathUtils; -import gobblin.util.commit.DeleteFileCommitStep; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.PreserveAttributes; +import org.apache.gobblin.data.management.copy.entities.PostPublishStep; +import org.apache.gobblin.data.management.copy.entities.PrePublishStep; +import org.apache.gobblin.source.extractor.ComparableWatermark; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.util.FileListUtils; +import org.apache.gobblin.util.PathUtils; +import org.apache.gobblin.util.commit.DeleteFileCommitStep; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/CopyRouteGeneratorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/CopyRouteGeneratorTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/CopyRouteGeneratorTest.java index 0154db2..6227742 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/CopyRouteGeneratorTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/CopyRouteGeneratorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.replication; +package org.apache.gobblin.data.management.copy.replication; import org.mockito.Mockito; @@ -25,8 +25,8 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.common.collect.ImmutableList; -import gobblin.source.extractor.ComparableWatermark; -import gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.source.extractor.ComparableWatermark; +import org.apache.gobblin.source.extractor.extract.LongWatermark; @Test(groups = { "gobblin.data.management.copy.replication" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ReplicationConfigurationTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ReplicationConfigurationTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ReplicationConfigurationTest.java index 3364d25..7ff7278 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ReplicationConfigurationTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/replication/ReplicationConfigurationTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.replication; +package org.apache.gobblin.data.management.copy.replication; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterTest.java index 7deecab..152081d 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.writer; +package org.apache.gobblin.data.management.copy.writer; import java.io.ByteArrayInputStream; import java.io.File; @@ -40,20 +40,20 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.crypto.EncryptionConfigParser; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopySource; -import gobblin.data.management.copy.CopyableDatasetMetadata; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.CopyableFileUtils; -import gobblin.data.management.copy.FileAwareInputStream; -import gobblin.data.management.copy.OwnerAndPermission; -import gobblin.data.management.copy.PreserveAttributes; -import gobblin.data.management.copy.TestCopyableDataset; -import gobblin.util.TestUtils; -import gobblin.util.io.StreamUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.crypto.EncryptionConfigParser; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopySource; +import org.apache.gobblin.data.management.copy.CopyableDatasetMetadata; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.CopyableFileUtils; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.data.management.copy.OwnerAndPermission; +import org.apache.gobblin.data.management.copy.PreserveAttributes; +import org.apache.gobblin.data.management.copy.TestCopyableDataset; +import org.apache.gobblin.util.TestUtils; +import org.apache.gobblin.util.io.StreamUtils; public class FileAwareInputStreamDataWriterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterTest.java index 3bed0a6..d2406bf 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterTest.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.writer; - -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.copy.CopySource; -import gobblin.data.management.copy.CopyableDatasetMetadata; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.CopyableFileUtils; -import gobblin.data.management.copy.FileAwareInputStream; -import gobblin.data.management.copy.OwnerAndPermission; -import gobblin.data.management.copy.TestCopyableDataset; -import gobblin.data.management.copy.converter.UnGzipConverter; -import gobblin.util.PathUtils; -import gobblin.util.TestUtils; +package org.apache.gobblin.data.management.copy.writer; + +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.copy.CopySource; +import org.apache.gobblin.data.management.copy.CopyableDatasetMetadata; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.CopyableFileUtils; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.data.management.copy.OwnerAndPermission; +import org.apache.gobblin.data.management.copy.TestCopyableDataset; +import org.apache.gobblin.data.management.copy.converter.UnGzipConverter; +import org.apache.gobblin.util.PathUtils; +import org.apache.gobblin.util.TestUtils; import java.io.FileInputStream; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/partition/FileSetTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/partition/FileSetTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/partition/FileSetTest.java index 74183d3..4c0af5e 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/partition/FileSetTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/partition/FileSetTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.partition; +package org.apache.gobblin.data.management.partition; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.Path; @@ -24,8 +24,8 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.dataset.DummyDataset; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.dataset.DummyDataset; public class FileSetTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicyTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicyTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicyTest.java index 8e173ba..d756ddc 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicyTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicyTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.ArrayList; import java.util.Collection; @@ -29,7 +29,7 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.DatasetVersion; /** Unit tests for {@link NewestKSelectionPolicy} */ public class NewestKSelectionPolicyTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/TimeBasedSelectionPolicyTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/TimeBasedSelectionPolicyTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/TimeBasedSelectionPolicyTest.java index 733f7b8..8e04813 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/TimeBasedSelectionPolicyTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/policy/TimeBasedSelectionPolicyTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Properties; @@ -28,7 +28,7 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CleanableDatasetBaseTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CleanableDatasetBaseTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CleanableDatasetBaseTest.java index aebb8f0..4d3fc3b 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CleanableDatasetBaseTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CleanableDatasetBaseTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import java.io.IOException; import java.util.Collection; @@ -32,14 +32,14 @@ import com.google.common.collect.Lists; import static org.mockito.Mockito.*; -import gobblin.data.management.retention.dataset.CleanableDatasetBase; -import gobblin.data.management.retention.policy.RetentionPolicy; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.data.management.retention.version.StringDatasetVersion; -import gobblin.data.management.retention.version.finder.DatasetVersionFinder; -import gobblin.data.management.retention.version.finder.VersionFinder; -import gobblin.data.management.trash.TestTrash; -import gobblin.data.management.trash.Trash; +import org.apache.gobblin.data.management.retention.dataset.CleanableDatasetBase; +import org.apache.gobblin.data.management.retention.policy.RetentionPolicy; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.StringDatasetVersion; +import org.apache.gobblin.data.management.retention.version.finder.DatasetVersionFinder; +import org.apache.gobblin.data.management.retention.version.finder.VersionFinder; +import org.apache.gobblin.data.management.trash.TestTrash; +import org.apache.gobblin.data.management.trash.Trash; public class CleanableDatasetBaseTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CombineRetentionPolicyTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CombineRetentionPolicyTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CombineRetentionPolicyTest.java index 8d2acd4..b441ed9 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CombineRetentionPolicyTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/CombineRetentionPolicyTest.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.data.management.retention; - -import gobblin.data.management.retention.policy.CombineRetentionPolicy; -import gobblin.data.management.retention.test.ContainsARetentionPolicy; -import gobblin.data.management.retention.test.ContainsBRetentionPolicy; -import gobblin.data.management.retention.test.ContainsCRetentionPolicy; -import gobblin.data.management.version.DatasetVersion; -import gobblin.data.management.version.FileStatusDatasetVersion; -import gobblin.data.management.version.StringDatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; +package org.apache.gobblin.data.management.retention; + +import org.apache.gobblin.data.management.retention.policy.CombineRetentionPolicy; +import org.apache.gobblin.data.management.retention.test.ContainsARetentionPolicy; +import org.apache.gobblin.data.management.retention.test.ContainsBRetentionPolicy; +import org.apache.gobblin.data.management.retention.test.ContainsCRetentionPolicy; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.FileStatusDatasetVersion; +import org.apache.gobblin.data.management.version.StringDatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; import javax.annotation.Nullable; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java index f9e9838..1a4311d 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import java.net.URI; import java.util.List; @@ -34,12 +34,12 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.policy.EmbeddedRetentionSelectionPolicy; -import gobblin.data.management.policy.NewestKSelectionPolicy; -import gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.finder.WatermarkDatasetVersionFinder; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.policy.EmbeddedRetentionSelectionPolicy; +import org.apache.gobblin.data.management.policy.NewestKSelectionPolicy; +import org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder; public class ConfigurableCleanableDatasetTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/DatasetVersionFinderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/DatasetVersionFinderTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/DatasetVersionFinderTest.java index 8e0bb70..260a385 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/DatasetVersionFinderTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/DatasetVersionFinderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import java.io.IOException; import java.util.List; @@ -32,11 +32,11 @@ import com.google.common.collect.Lists; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.data.management.retention.version.StringDatasetVersion; -import gobblin.data.management.retention.version.finder.DatasetVersionFinder; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.StringDatasetVersion; +import org.apache.gobblin.data.management.retention.version.finder.DatasetVersionFinder; +import org.apache.gobblin.dataset.FileSystemDataset; public class DatasetVersionFinderTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/FsCleanableHelperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/FsCleanableHelperTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/FsCleanableHelperTest.java index 585810a..b812798 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/FsCleanableHelperTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/FsCleanableHelperTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.Matchers.instanceOf; @@ -42,10 +42,10 @@ import com.google.common.collect.Sets; import com.google.common.io.Files; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.retention.dataset.FsCleanableHelper; -import gobblin.data.management.trash.MockTrash; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.retention.dataset.FsCleanableHelper; +import org.apache.gobblin.data.management.trash.MockTrash; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.dataset.FileSystemDataset; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/NewestKRetentionPolicyTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/NewestKRetentionPolicyTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/NewestKRetentionPolicyTest.java index 6a4d1ec..0183688 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/NewestKRetentionPolicyTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/NewestKRetentionPolicyTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import java.util.List; import java.util.Properties; @@ -26,9 +26,9 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.data.management.retention.policy.NewestKRetentionPolicy; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.data.management.retention.version.StringDatasetVersion; +import org.apache.gobblin.data.management.retention.policy.NewestKRetentionPolicy; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.StringDatasetVersion; public class NewestKRetentionPolicyTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimeBasedRetentionPolicyTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimeBasedRetentionPolicyTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimeBasedRetentionPolicyTest.java index cbee23c..077d552 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimeBasedRetentionPolicyTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimeBasedRetentionPolicyTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import static org.hamcrest.MatcherAssert.assertThat; @@ -32,8 +32,8 @@ import org.testng.annotations.Test; import com.google.common.collect.ImmutableList; import com.google.common.collect.Lists; -import gobblin.data.management.retention.policy.TimeBasedRetentionPolicy; -import gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.retention.policy.TimeBasedRetentionPolicy; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; @Test(groups = { "SystemTimeTests"}) public class TimeBasedRetentionPolicyTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimestampedDatasetVersionFinderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimestampedDatasetVersionFinderTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimestampedDatasetVersionFinderTest.java index 7201489..e03f3bb 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimestampedDatasetVersionFinderTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/TimestampedDatasetVersionFinderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import java.util.Properties; @@ -31,10 +31,10 @@ import org.testng.annotations.Test; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.retention.version.TimestampedDatasetVersion; -import gobblin.data.management.retention.version.finder.DateTimeDatasetVersionFinder; -import gobblin.util.PathUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.retention.version.finder.DateTimeDatasetVersionFinder; +import org.apache.gobblin.util.PathUtils; public class TimestampedDatasetVersionFinderTest {
