http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java index 73feb1d..eae084f 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.qualitychecker.row; +package org.apache.gobblin.qualitychecker.row; import java.util.List; import java.util.stream.Collectors;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java index c91bf3c..3bd8338 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package gobblin.recordaccess; +package org.apache.gobblin.recordaccess; import java.io.ByteArrayOutputStream; import java.io.File; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java b/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java index 53da61a..99f819b 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package gobblin.recordaccess; +package org.apache.gobblin.recordaccess; import java.io.IOException; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java b/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java index c7e9b6c..34b3e98 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java @@ -1,4 +1,4 @@ -package gobblin.security.ssl; +package org.apache.gobblin.security.ssl; import java.io.IOException; import java.util.HashMap; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java b/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java index 1dda0a5..ec7086e 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.serde; +package org.apache.gobblin.serde; import java.io.FileReader; import java.io.IOException; @@ -34,22 +34,22 @@ import com.google.common.collect.ImmutableList; import com.google.common.collect.Iterators; import com.google.common.io.Closer; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.converter.serde.HiveSerDeConverter; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.hadoop.OldApiWritableFileExtractor; -import gobblin.source.extractor.hadoop.OldApiWritableFileSource; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.HadoopUtils; -import gobblin.writer.Destination; -import gobblin.writer.Destination.DestinationType; -import gobblin.writer.HiveWritableHdfsDataWriter; -import gobblin.writer.HiveWritableHdfsDataWriterBuilder; -import gobblin.writer.WriterOutputFormat; +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.converter.DataConversionException; +import org.apache.gobblin.converter.serde.HiveSerDeConverter; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.hadoop.OldApiWritableFileExtractor; +import org.apache.gobblin.source.extractor.hadoop.OldApiWritableFileSource; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.HadoopUtils; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.Destination.DestinationType; +import org.apache.gobblin.writer.HiveWritableHdfsDataWriter; +import org.apache.gobblin.writer.HiveWritableHdfsDataWriterBuilder; +import org.apache.gobblin.writer.WriterOutputFormat; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java index 208a5ae..cb35eb6 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.source; +package org.apache.gobblin.source; import java.io.IOException; import java.nio.file.FileVisitResult; @@ -30,8 +30,8 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; public class RegexBasedPartitionedRetrieverTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java index 145c522..be4f161 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java @@ -10,7 +10,7 @@ * CONDITIONS OF ANY KIND, either express or implied. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import java.io.File; import java.io.IOException; @@ -29,23 +29,23 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.DatePartitionedAvroFileSource; -import gobblin.source.workunit.Extract.TableType; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; -import gobblin.stream.RecordEnvelope; -import gobblin.writer.AvroDataWriterBuilder; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; -import gobblin.writer.Destination; -import gobblin.writer.PartitionedDataWriter; -import gobblin.writer.WriterOutputFormat; -import gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner; -import gobblin.writer.partitioner.TimeBasedWriterPartitioner; +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.DatePartitionedAvroFileSource; +import org.apache.gobblin.source.workunit.Extract.TableType; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.writer.AvroDataWriterBuilder; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.PartitionedDataWriter; +import org.apache.gobblin.writer.WriterOutputFormat; +import org.apache.gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner; +import org.apache.gobblin.writer.partitioner.TimeBasedWriterPartitioner; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java index 826be4b..d1641ac 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java @@ -1,18 +1,18 @@ -package gobblin.source.extractor.extract; - -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.exception.HighWatermarkException; -import gobblin.source.extractor.exception.RecordCountException; -import gobblin.source.extractor.exception.SchemaException; -import gobblin.source.extractor.partition.Partition; -import gobblin.source.extractor.partition.Partitioner; -import gobblin.source.extractor.watermark.Predicate; -import gobblin.source.extractor.watermark.WatermarkPredicate; -import gobblin.source.extractor.watermark.WatermarkType; -import gobblin.source.workunit.WorkUnit; +package org.apache.gobblin.source.extractor.extract; + +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.exception.HighWatermarkException; +import org.apache.gobblin.source.extractor.exception.RecordCountException; +import org.apache.gobblin.source.extractor.exception.SchemaException; +import org.apache.gobblin.source.extractor.partition.Partition; +import org.apache.gobblin.source.extractor.partition.Partitioner; +import org.apache.gobblin.source.extractor.watermark.Predicate; +import org.apache.gobblin.source.extractor.watermark.WatermarkPredicate; +import org.apache.gobblin.source.extractor.watermark.WatermarkType; +import org.apache.gobblin.source.workunit.WorkUnit; import java.io.IOException; import java.util.ArrayList; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java index d552574..c589660 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.source.extractor.extract; +package org.apache.gobblin.source.extractor.extract; import java.util.ArrayList; import java.util.List; @@ -27,16 +27,16 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.common.collect.ImmutableSet; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.configuration.WorkUnitState.WorkingState; -import gobblin.source.extractor.extract.QueryBasedSource.SourceEntity; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.Extract.TableType; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.dataset.DatasetUtils; +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.configuration.WorkUnitState.WorkingState; +import org.apache.gobblin.source.extractor.extract.QueryBasedSource.SourceEntity; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.Extract.TableType; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.dataset.DatasetUtils; /** * Unit tests for {@link QueryBasedSource} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java index bfb0a28..e91cc08 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.filebased; +package org.apache.gobblin.source.extractor.filebased; import java.io.IOException; @@ -28,10 +28,10 @@ import org.mockito.Mockito; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; @Test http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java index e8cdfe7..8cceff2 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.source.extractor.filebased; - -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.WorkUnit; +package org.apache.gobblin.source.extractor.filebased; + +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.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; import org.junit.Assert; import org.testng.annotations.Test; import org.testng.collections.Lists; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java index 1cedba8..a7c7637 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.filebased; +package org.apache.gobblin.source.extractor.filebased; import java.io.ByteArrayInputStream; import java.io.InputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java index ba2fa5f..af5908b 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.hadoop; +package org.apache.gobblin.source.extractor.hadoop; import java.io.IOException; import java.util.List; @@ -31,9 +31,9 @@ import org.testng.annotations.Test; import com.google.common.io.Closer; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java index 5af0a53..bb52d92 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.source.extractor.hadoop; +package org.apache.gobblin.source.extractor.hadoop; import java.io.IOException; import java.io.InputStream; import java.net.URL; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.source.extractor.filebased.FileBasedHelperException; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException; import org.apache.commons.io.IOUtils; import org.apache.hadoop.conf.Configuration; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java index 104e06b..e28c4a4 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.hadoop; +package org.apache.gobblin.source.extractor.hadoop; import java.io.File; import java.io.IOException; @@ -34,12 +34,12 @@ import org.testng.annotations.Test; import com.google.common.io.Closer; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.workunit.Extract; -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.source.extractor.DataRecordException; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java index cfad7b9..d4d2811 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java @@ -1,4 +1,4 @@ -package gobblin.source.extractor.partition; +package org.apache.gobblin.source.extractor.partition; import java.util.ArrayList; import java.util.Collections; @@ -8,11 +8,11 @@ import org.joda.time.DateTime; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.source.extractor.extract.ExtractType; -import gobblin.source.extractor.utils.Utils; -import gobblin.source.extractor.watermark.WatermarkType; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.source.extractor.extract.ExtractType; +import org.apache.gobblin.source.extractor.utils.Utils; +import org.apache.gobblin.source.extractor.watermark.WatermarkType; /** * Unit tests for {@link PartitionerTest} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java index 12b0861..2466fdc 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.watermark; +package org.apache.gobblin.source.extractor.watermark; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java index 5654bd9..a631cfd 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.watermark; +package org.apache.gobblin.source.extractor.watermark; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java index dbbc845..d4d8754 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.watermark; +package org.apache.gobblin.source.extractor.watermark; import java.util.HashMap; import java.util.Map; @@ -24,7 +24,7 @@ import org.testng.Assert; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.source.extractor.extract.QueryBasedExtractor; +import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java index 6720da5..bc94a4b 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.watermark; +package org.apache.gobblin.source.extractor.watermark; import java.text.ParseException; import java.text.SimpleDateFormat; @@ -28,7 +28,7 @@ import org.testng.Assert; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java index 3ee8f0e..cd34f04 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java b/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java index fa6c55d..7adca72 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.state; +package org.apache.gobblin.state; import java.util.Properties; @@ -24,8 +24,8 @@ import org.testng.annotations.Test; import com.google.common.collect.ImmutableMap; -import gobblin.Constructs; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.Constructs; +import org.apache.gobblin.configuration.WorkUnitState; public class ConstructStateTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java index b729a18..bbe772d 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.File; import java.io.IOException; @@ -38,9 +38,9 @@ import com.google.gson.Gson; import com.google.gson.JsonElement; import com.google.gson.reflect.TypeToken; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.util.FinalState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.FinalState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java index 84a81ec..11b2274 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.ArrayList; @@ -24,9 +24,9 @@ import java.util.function.Supplier; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.stream.RecordEnvelope; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.stream.RecordEnvelope; public class CloseOnFlushWriterWrapperTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java index f86752f..8d73aec 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.source.extractor.DefaultCheckpointableWatermark; -import gobblin.stream.RecordEnvelope; -import gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.extractor.extract.LongWatermark; import static org.mockito.Mockito.mock; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java index 4c28d81..ab18c49 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java index e73e75d..8eaee91 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java @@ -1,4 +1,4 @@ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Arrays; @@ -7,11 +7,11 @@ import org.testng.Assert; import org.testng.annotations.BeforeMethod; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.metadata.types.GlobalMetadata; -import gobblin.metadata.types.Metadata; -import gobblin.type.RecordWithMetadata; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.metadata.types.Metadata; +import org.apache.gobblin.type.RecordWithMetadata; public class MetadataWriterWrapperTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java index 92275c2..6db9cf9 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Collections; @@ -26,14 +26,14 @@ import org.apache.avro.generic.GenericRecord; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.source.extractor.DefaultCheckpointableWatermark; -import gobblin.stream.RecordEnvelope; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.writer.test.TestPartitionAwareWriterBuilder; -import gobblin.writer.test.TestPartitioner; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.writer.test.TestPartitionAwareWriterBuilder; +import org.apache.gobblin.writer.test.TestPartitioner; import static org.mockito.Matchers.any; import static org.mockito.Mockito.mock; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java index fb1f694..e0d6883 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import static org.mockito.Mockito.*; import java.io.IOException; -import gobblin.configuration.State; -import gobblin.stream.RecordEnvelope; -import gobblin.writer.exception.NonTransientException; -import gobblin.util.FinalState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.writer.exception.NonTransientException; +import org.apache.gobblin.util.FinalState; import org.junit.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java index fd2d5d8..020ad5e 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.BufferedReader; import java.io.DataInputStream; @@ -41,11 +41,11 @@ import org.testng.annotations.Test; import com.google.common.collect.ImmutableList; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.crypto.EncryptionConfigParser; -import gobblin.crypto.EncryptionFactory; -import gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.crypto.EncryptionConfigParser; +import org.apache.gobblin.crypto.EncryptionFactory; +import org.apache.gobblin.metadata.types.GlobalMetadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java index 71e7f0a..8af13b8 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; /** * Test constants. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java index b945b45..0fd4dd1 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import static org.mockito.Mockito.*; import java.io.IOException; import java.util.concurrent.TimeUnit; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.writer.ThrottleWriter.ThrottleType; -import gobblin.util.FinalState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.writer.ThrottleWriter.ThrottleType; +import org.apache.gobblin.util.FinalState; import org.apache.commons.lang3.mutable.MutableLong; import org.mockito.invocation.InvocationOnMock; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java index 2d8ec90..07adcc0 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java @@ -14,19 +14,19 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer.http; +package org.apache.gobblin.writer.http; import static org.mockito.Mockito.*; -import static gobblin.writer.http.SalesForceRestWriterBuilder.*; +import static org.apache.gobblin.writer.http.SalesForceRestWriterBuilder.*; import java.io.ByteArrayInputStream; import java.io.IOException; import java.net.URI; import java.net.URISyntaxException; -import gobblin.configuration.State; -import gobblin.converter.http.RestEntry; -import gobblin.writer.http.SalesforceRestWriter.Operation; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.http.RestEntry; +import org.apache.gobblin.writer.http.SalesforceRestWriter.Operation; import org.apache.http.HttpEntity; import org.apache.http.StatusLine; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java index 2214dcd..cd2ae9e 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer.objectstore; +package org.apache.gobblin.writer.objectstore; import java.io.IOException; import java.io.InputStream; @@ -34,10 +34,10 @@ import com.google.common.collect.Maps; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.objectstore.ObjectStoreDeleteConverter; -import gobblin.writer.objectstore.response.GetObjectResponse; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.objectstore.ObjectStoreDeleteConverter; +import org.apache.gobblin.writer.objectstore.response.GetObjectResponse; public class ObjectStoreWriterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java index 6d4d719..dbb0522 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer.partitioner; +package org.apache.gobblin.writer.partitioner; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java index 65fa24f..e593aa1 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer.partitioner; +package org.apache.gobblin.writer.partitioner; import java.io.File; import java.io.IOException; @@ -31,15 +31,15 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.stream.RecordEnvelope; -import gobblin.writer.AvroDataWriterBuilder; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; -import gobblin.writer.Destination; -import gobblin.writer.PartitionedDataWriter; -import gobblin.writer.WriterOutputFormat; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.writer.AvroDataWriterBuilder; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.PartitionedDataWriter; +import org.apache.gobblin.writer.WriterOutputFormat; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java index 3b0c1bd..026f0a7 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer.test; +package org.apache.gobblin.writer.test; import java.io.IOException; import java.util.concurrent.TimeoutException; @@ -22,9 +22,9 @@ import java.util.concurrent.TimeoutException; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.source.workunit.WorkUnit; -import gobblin.writer.Destination; -import gobblin.writer.Destination.DestinationType; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.Destination.DestinationType; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java index 75fe6c5..8b1e0ca 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer.test; +package org.apache.gobblin.writer.test; import java.io.IOException; import java.util.Queue; @@ -24,9 +24,9 @@ import org.apache.avro.Schema; import com.google.common.collect.Queues; -import gobblin.commit.SpeculativeAttemptAwareConstruct; -import gobblin.writer.DataWriter; -import gobblin.writer.PartitionAwareDataWriterBuilder; +import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.PartitionAwareDataWriterBuilder; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java index dfdce01..affdf20 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.writer.test; +package org.apache.gobblin.writer.test; -import gobblin.configuration.State; -import gobblin.writer.partitioner.WriterPartitioner; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.writer.partitioner.WriterPartitioner; import org.apache.avro.Schema; import org.apache.avro.SchemaBuilder; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java index a9a8cd3..8a4bf39 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer.test; +package org.apache.gobblin.writer.test; import java.io.IOException; import java.util.Arrays; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/resources/converter/record_with_arrays.avsc ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/resources/converter/record_with_arrays.avsc b/gobblin-core/src/test/resources/converter/record_with_arrays.avsc index ba6beb5..b979e0a 100644 --- a/gobblin-core/src/test/resources/converter/record_with_arrays.avsc +++ b/gobblin-core/src/test/resources/converter/record_with_arrays.avsc @@ -1,7 +1,7 @@ { "name": "NestedTestRecord", "type": "record", - "namespace": "gobblin.test", + "namesapce" : "org.apache.gobblin.test", "fields": [ { "name": "fieldToEncrypt", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java index cadee5d..4d99825 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.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.avro; +package org.apache.gobblin.data.management.conversion.hive.avro; import java.io.IOException; import java.net.URI; @@ -36,12 +36,12 @@ import com.google.common.base.Preconditions; import com.google.common.collect.Maps; import com.google.common.hash.Hashing; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator; -import gobblin.hive.avro.HiveAvroSerDeManager; -import gobblin.util.AvroUtils; -import gobblin.util.HadoopUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator; +import org.apache.gobblin.hive.avro.HiveAvroSerDeManager; +import org.apache.gobblin.util.AvroUtils; +import org.apache.gobblin.util.HadoopUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java index f954087..0f7e09d 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.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.avro; +package org.apache.gobblin.data.management.conversion.hive.avro; /** * An exception thrown when Schema was not found. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java index a9265b7..4687276 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.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.Arrays; @@ -53,23 +53,23 @@ import com.google.common.collect.ImmutableMap; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig; -import gobblin.data.management.conversion.hive.entities.QueryBasedHiveConversionEntity; -import gobblin.data.management.conversion.hive.entities.QueryBasedHivePublishEntity; -import gobblin.data.management.conversion.hive.events.EventWorkunitUtils; -import gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.data.management.copy.hive.HiveUtils; -import gobblin.data.management.copy.hive.WhitelistBlacklist; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.metrics.event.sla.SlaEventKeys; -import gobblin.util.AutoReturnableObject; -import gobblin.util.HadoopUtils; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig; +import org.apache.gobblin.data.management.conversion.hive.entities.QueryBasedHiveConversionEntity; +import org.apache.gobblin.data.management.conversion.hive.entities.QueryBasedHivePublishEntity; +import org.apache.gobblin.data.management.conversion.hive.events.EventWorkunitUtils; +import org.apache.gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.data.management.copy.hive.HiveUtils; +import org.apache.gobblin.data.management.copy.hive.WhitelistBlacklist; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.metrics.event.sla.SlaEventKeys; +import org.apache.gobblin.util.AutoReturnableObject; +import org.apache.gobblin.util.HadoopUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java index cc392e0..51fa101 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java @@ -14,13 +14,13 @@ * 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 org.apache.avro.Schema; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig; -import gobblin.util.AvroFlattener; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig; +import org.apache.gobblin.util.AvroFlattener; /** * An Avro to ORC converter for avro to flattened ORC. {@link OrcFormats#FLATTENED_ORC} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java index b786cee..8bf01cf 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java @@ -14,12 +14,12 @@ * 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 org.apache.avro.Schema; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java index 07f8854..ba42811 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.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.util.List; import java.util.Map; @@ -34,10 +34,10 @@ import com.google.common.collect.Maps; import com.google.common.collect.Sets; import com.typesafe.config.Config; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java index 7be1320..61fbd31 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.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.IOException; import java.util.Properties; @@ -24,8 +24,8 @@ import org.apache.hadoop.hive.metastore.api.Table; import com.typesafe.config.Config; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.metrics.event.EventSubmitter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java index 1cf9836..1486fe5 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.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.entities; +package org.apache.gobblin.data.management.conversion.hive.entities; import java.util.List; @@ -25,15 +25,15 @@ import lombok.ToString; import com.google.common.base.Optional; import com.google.common.collect.Lists; -import gobblin.converter.Converter; -import gobblin.data.management.conversion.hive.converter.AbstractAvroToOrcConverter; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; -import gobblin.data.management.conversion.hive.extractor.HiveConvertExtractor; -import gobblin.data.management.conversion.hive.writer.HiveQueryExecutionWriter; -import gobblin.hive.HivePartition; -import gobblin.hive.HiveRegistrationUnit; -import gobblin.hive.HiveTable; -import gobblin.source.extractor.Extractor; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.data.management.conversion.hive.converter.AbstractAvroToOrcConverter; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; +import org.apache.gobblin.data.management.conversion.hive.extractor.HiveConvertExtractor; +import org.apache.gobblin.data.management.conversion.hive.writer.HiveQueryExecutionWriter; +import org.apache.gobblin.hive.HivePartition; +import org.apache.gobblin.hive.HiveRegistrationUnit; +import org.apache.gobblin.hive.HiveTable; +import org.apache.gobblin.source.extractor.Extractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java index 01d2156..26ab758 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.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.entities; +package org.apache.gobblin.data.management.conversion.hive.entities; import java.util.List; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java index 6bc4bb1..9e1828e 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.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.entities; +package org.apache.gobblin.data.management.conversion.hive.entities; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java index a985258..575ccc2 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.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.entities; +package org.apache.gobblin.data.management.conversion.hive.entities; import lombok.EqualsAndHashCode; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java index 0cf0719..826c489 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive.events; +package org.apache.gobblin.data.management.conversion.hive.events; -import gobblin.metrics.event.sla.SlaEventKeys; +import org.apache.gobblin.metrics.event.sla.SlaEventKeys; /** * Event names and metadata names used by hive conversion. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java index 5da1680..71c821d 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java @@ -14,19 +14,19 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive.events; +package org.apache.gobblin.data.management.conversion.hive.events; import java.util.List; import org.apache.hadoop.hive.ql.metadata.Partition; import org.apache.hadoop.hive.ql.metadata.Table; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.metrics.event.sla.SlaEventKeys; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metrics.event.sla.SlaEventKeys; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.source.workunit.WorkUnit; /** * Utilities to set event metadata into {@link WorkUnit}s http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java index 4eb3263..107fa89 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.data.management.conversion.hive.extractor; +package org.apache.gobblin.data.management.conversion.hive.extractor; import java.io.IOException; import com.google.common.base.Optional; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.conversion.hive.source.HiveWorkUnit; -import gobblin.data.management.conversion.hive.watermarker.PartitionLevelWatermarker; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.source.extractor.Extractor; +import org.apache.gobblin.configuration.WorkUnitState; +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.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.source.extractor.Extractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java index 08680ec..d5a3489 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.data.management.conversion.hive.extractor; +package org.apache.gobblin.data.management.conversion.hive.extractor; import java.io.IOException; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.thrift.TException; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java index c02d41e..c00292b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.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.extractor; +package org.apache.gobblin.data.management.conversion.hive.extractor; import java.io.IOException; import java.util.List; @@ -33,16 +33,16 @@ import org.apache.thrift.TException; import com.google.common.base.Optional; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.conversion.hive.avro.AvroSchemaManager; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; -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.conversion.hive.watermarker.PartitionLevelWatermarker; -import gobblin.source.extractor.DataRecordException; -import gobblin.util.AutoReturnableObject; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.conversion.hive.avro.AvroSchemaManager; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; +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.conversion.hive.watermarker.PartitionLevelWatermarker; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.util.AutoReturnableObject; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java index 4a2c48c..4a190d8 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.data.management.conversion.hive.extractor; +package org.apache.gobblin.data.management.conversion.hive.extractor; import java.io.IOException; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.hive.ql.metadata.HiveException; import org.apache.thrift.TException; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java index 16154b3..6337856 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.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 java.util.Arrays; @@ -27,7 +27,7 @@ import org.joda.time.DateTimeZone; import org.joda.time.format.DateTimeFormat; import org.joda.time.format.DateTimeFormatter; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java index 7eaa369..bd2fe77 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.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 java.io.IOException; import java.util.concurrent.Callable; @@ -30,8 +30,8 @@ import org.apache.hadoop.hive.ql.metadata.Table; import com.google.common.cache.Cache; import com.google.common.cache.CacheBuilder; -import gobblin.hive.HivePartition; -import gobblin.hive.HiveTable; +import org.apache.gobblin.hive.HivePartition; +import org.apache.gobblin.hive.HiveTable; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java index 619a274..2c33ef9 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.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 java.util.concurrent.TimeUnit; @@ -23,7 +23,7 @@ import lombok.NoArgsConstructor; import org.apache.hadoop.hive.ql.metadata.Partition; import org.apache.hadoop.hive.ql.metadata.Table; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /**
