http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java index fbd3c32..bb05f97 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java @@ -17,12 +17,12 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.io.IOException; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java index 500032f..378d467 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Map; @@ -32,8 +32,8 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.util.ExecutorsUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java index cc33532..9c9ef83 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java @@ -17,14 +17,14 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Map; -import gobblin.annotation.Alpha; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.stream.RecordEnvelope; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.stream.RecordEnvelope; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java index 72fff25..e4ef251 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java @@ -17,15 +17,15 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Map; import com.google.common.base.Optional; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.stream.RecordEnvelope; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java index 0d00f27..346eb60 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.util.Collections; @@ -26,7 +26,7 @@ import java.util.Map; import lombok.Getter; import lombok.ToString; -import gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java index 1228223..8500774 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java @@ -17,11 +17,11 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.Map; -import gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java index f319722..92c26a1 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import com.google.common.base.Preconditions; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java index ffa5fbf..fa93067 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; -import gobblin.async.Callback; +import org.apache.gobblin.async.Callback; public interface WriteCallback<T> extends Callback<WriteResponse<T>> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java index 8661f8c..4f22c95 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; /** * A class for encapsulating the system-native response and general statistics from a write http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java index 92e7451..64666d0 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java index e2d959e..7c69084 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; /** * An interface to implement a transformer from a system-native response type into a {@link WriteResponse}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java index 85d265f..26e4a0b 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer.exception; +package org.apache.gobblin.writer.exception; /** * NonTransientException that shows this is a permanent failure where retry cannot solve. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java index c1a0e32..7246f47 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.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-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java index 4dd1915..01ec3b4 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.util.List; import java.util.Map; @@ -30,10 +30,10 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.collect.Sets; -import gobblin.configuration.WorkUnitState; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.stream.RecordEnvelope; -import gobblin.util.ExponentialBackoff; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.util.ExponentialBackoff; import io.reactivex.Flowable; import io.reactivex.schedulers.Schedulers; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java index 88ce969..0127419 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.util.Iterator; import java.util.Properties; @@ -26,7 +26,7 @@ import java.util.Random; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; @Test http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java index a5bd8f8..e29bf48 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java index 86df7d5..669d040 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.filter; +package org.apache.gobblin.converter.filter; import java.io.IOException; import java.io.InputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java index 66dbe16..596ae69 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.filter; +package org.apache.gobblin.converter.filter; import java.io.IOException; import java.util.Properties; @@ -24,8 +24,8 @@ import org.apache.avro.Schema; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.SchemaConversionException; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.SchemaConversionException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java index 1b25085..68fbf37 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.crypto; +package org.apache.gobblin.crypto; import java.util.Map; import java.util.Properties; @@ -23,8 +23,8 @@ import org.testng.Assert; import org.testng.annotations.BeforeTest; import org.testng.annotations.Test; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; public class EncryptionConfigParserTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java index 20702d3..fb5dfeb 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java @@ -15,22 +15,22 @@ * limitations under the License. */ -package gobblin.instrumented.converter; +package org.apache.gobblin.instrumented.converter; import java.util.Map; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.MetricsHelper; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.Constructs; -import gobblin.converter.DataConversionException; -import gobblin.converter.IdentityConverter; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.metrics.MetricNames; +import org.apache.gobblin.MetricsHelper; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.Constructs; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.IdentityConverter; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.metrics.MetricNames; public class InstrumentedConverterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java index b3d607a..71b1bae 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented.extractor; +package org.apache.gobblin.instrumented.extractor; import java.io.IOException; import java.util.Map; @@ -24,15 +24,15 @@ import java.util.concurrent.atomic.AtomicBoolean; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.MetricsHelper; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.Constructs; -import gobblin.metrics.MetricNames; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; -import gobblin.stream.RecordEnvelope; +import org.apache.gobblin.MetricsHelper; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.Constructs; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.stream.RecordEnvelope; public class InstrumentedExtractorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java index bc25b3c..b7ed80f 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented.fork; +package org.apache.gobblin.instrumented.fork; import java.io.IOException; import java.util.ArrayList; @@ -25,12 +25,12 @@ import java.util.Map; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.MetricsHelper; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.Constructs; -import gobblin.fork.ForkOperator; -import gobblin.metrics.MetricNames; +import org.apache.gobblin.MetricsHelper; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.Constructs; +import org.apache.gobblin.fork.ForkOperator; +import org.apache.gobblin.metrics.MetricNames; public class InstrumentedForkOperatorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java index e72a4af..9caf850 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package gobblin.instrumented.qualitychecker; +package org.apache.gobblin.instrumented.qualitychecker; import java.util.Map; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.MetricsHelper; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.Constructs; -import gobblin.configuration.WorkUnitState; -import gobblin.metrics.MetricNames; -import gobblin.qualitychecker.row.RowLevelPolicy; +import org.apache.gobblin.MetricsHelper; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.Constructs; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicy; public class InstrumentedRowLevelPolicyTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java index afb06ac..b912b59 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented.writer; +package org.apache.gobblin.instrumented.writer; import java.io.IOException; import java.util.Map; @@ -23,14 +23,14 @@ import java.util.Map; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.MetricsHelper; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.Constructs; -import gobblin.configuration.WorkUnitState; -import gobblin.metrics.MetricNames; -import gobblin.stream.RecordEnvelope; -import gobblin.writer.DataWriter; +import org.apache.gobblin.MetricsHelper; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.Constructs; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.writer.DataWriter; public class InstrumentedDataWriterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java index 6a7a775..02b14136 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract; +package org.apache.gobblin.source.extractor.extract; import java.io.IOException; import java.util.Collections; @@ -27,13 +27,13 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -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.Extractor; -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.configuration.WorkUnitState.WorkingState; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; @Test(groups = { "gobblin.source.extractor.extract" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java index 8b1a249..fcc1c3c 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Properties; @@ -34,15 +34,15 @@ import com.typesafe.config.ConfigFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.metrics.RootMetricContext; -import gobblin.metrics.reporter.OutputStreamReporter; -import gobblin.test.ConstantTimingType; -import gobblin.test.ErrorManager; -import gobblin.test.NthTimingType; -import gobblin.test.TestUtils; -import gobblin.test.TimingManager; -import gobblin.test.TimingResult; -import gobblin.test.TimingType; +import org.apache.gobblin.metrics.RootMetricContext; +import org.apache.gobblin.metrics.reporter.OutputStreamReporter; +import org.apache.gobblin.test.ConstantTimingType; +import org.apache.gobblin.test.ErrorManager; +import org.apache.gobblin.test.NthTimingType; +import org.apache.gobblin.test.TestUtils; +import org.apache.gobblin.test.TimingManager; +import org.apache.gobblin.test.TimingResult; +import org.apache.gobblin.test.TimingType; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java index 382a6da..59f231e 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Map; @@ -38,10 +38,10 @@ import com.typesafe.config.ConfigFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.source.extractor.DefaultCheckpointableWatermark; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.util.ExecutorsUtils; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java index 6136ba4..c07d9c4 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.ArrayList; @@ -31,10 +31,10 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; -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.Matchers.any; import static org.mockito.Mockito.*; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java index 6ba7263..168004a 100644 --- a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java +++ b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java @@ -17,13 +17,13 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.source.extractor.DefaultCheckpointableWatermark; -import gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark; +import org.apache.gobblin.source.extractor.extract.LongWatermark; @Test http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java index 8422ad8..f50c802 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.async; +package org.apache.gobblin.async; import java.util.Queue; import java.util.concurrent.ArrayBlockingQueue; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java index e6bb642..c0aad92 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.async; +package org.apache.gobblin.async; import java.util.ArrayList; import java.util.List; @@ -23,7 +23,7 @@ import java.util.List; import lombok.Getter; import lombok.Setter; -import gobblin.net.Request; +import org.apache.gobblin.net.Request; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java index 546db86..6c66218 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.async; +package org.apache.gobblin.async; import java.util.Queue; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java b/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java index 474d0a9..4a43016 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.async; +package org.apache.gobblin.async; import lombok.AllArgsConstructor; import lombok.Getter; -import gobblin.async.Callback; +import org.apache.gobblin.async.Callback; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java b/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java index 7e419a0..5eed080 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.async; +package org.apache.gobblin.async; /** * Exception for dispatching failures. By default, it is a fatal exception http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java b/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java index 7e0d30a..a4bb223 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.commit; +package org.apache.gobblin.commit; import java.io.IOException; import java.net.URI; @@ -25,10 +25,10 @@ import org.apache.hadoop.fs.Path; import com.google.common.base.Preconditions; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.util.HadoopUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.HadoopUtils; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java b/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java index 6c66ef2..6bb5903 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.commit; +package org.apache.gobblin.commit; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java index 0ecb64d..875b2fc 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.config; +package org.apache.gobblin.config; import java.util.HashMap; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java index dec1924..c6aee6b 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; /** * @deprecated. Please use {@link gobblin.util.EmptyIterable} instead. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java index c5d0bd2..3a9526b 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.io.IOException; import java.io.InputStream; @@ -31,7 +31,7 @@ import com.google.common.base.Function; import com.google.common.collect.Iterables; import com.google.common.collect.Lists; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java index fbe8001..1dcfa34 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; -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/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java index 455c8f1..f8114b7 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; @@ -23,15 +23,15 @@ import org.apache.avro.generic.GenericRecord; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.converter.Converter; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.converter.EmptyIterable; -import gobblin.util.AvroUtils; -import gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.EmptyIterable; +import org.apache.gobblin.util.AvroUtils; +import org.apache.gobblin.util.ForkOperatorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java index d13c594..b1d8079 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; import java.rmi.server.UID; @@ -26,10 +26,10 @@ import org.apache.hadoop.hive.serde2.avro.AvroGenericRecordWritable; import com.google.common.collect.Lists; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java index 7420f8b..13d1d0a 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java @@ -15,18 +15,18 @@ * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.fork.CopyableGenericRecord; -import gobblin.fork.CopyableSchema; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.fork.CopyableGenericRecord; +import org.apache.gobblin.fork.CopyableSchema; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java index a89b0d6..ecf98d4 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; import java.io.ByteArrayOutputStream; import java.io.IOException; @@ -26,10 +26,10 @@ import org.apache.avro.generic.GenericRecord; import org.apache.avro.io.BinaryEncoder; import org.apache.avro.io.EncoderFactory; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java index 285777c..bdb8fb3 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; import java.io.IOException; import java.util.Collections; @@ -27,10 +27,10 @@ import org.apache.avro.io.DecoderFactory; import com.google.common.base.Preconditions; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java index 9506ba3..ccf0819 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; import java.util.ArrayList; import java.util.List; @@ -31,15 +31,15 @@ import com.google.common.base.Optional; import com.google.common.collect.Maps; import com.typesafe.config.Config; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.util.AvroUtils; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.util.AvroUtils; +import org.apache.gobblin.util.ConfigUtils; -import static gobblin.util.AvroUtils.FIELD_LOCATION_DELIMITER; +import static org.apache.gobblin.util.AvroUtils.FIELD_LOCATION_DELIMITER; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java index 22916a9..aa015a1 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; import java.io.UnsupportedEncodingException; import java.nio.ByteBuffer; @@ -39,8 +39,8 @@ import com.google.gson.JsonArray; import com.google.gson.JsonElement; import com.google.gson.JsonObject; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java index 92eb3fc..0735c03 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; import java.io.IOException; import java.util.ArrayList; @@ -37,15 +37,15 @@ import com.google.gson.JsonArray; import com.google.gson.JsonElement; import com.google.gson.JsonObject; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.converter.EmptyIterable; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.converter.ToAvroConverterBase; -import gobblin.util.AvroUtils; -import gobblin.util.WriterUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.EmptyIterable; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.converter.ToAvroConverterBase; +import org.apache.gobblin.util.AvroUtils; +import org.apache.gobblin.util.WriterUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java index 69ca6a0..260c638 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.avro; +package org.apache.gobblin.converter.avro; public class UnsupportedDateTypeException extends Exception { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java index ba093c2..8672b6b 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.converter.csv; +package org.apache.gobblin.converter.csv; -import gobblin.converter.Converter; -import gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.SingleRecordIterable; import java.io.IOException; import java.util.List; @@ -30,11 +30,11 @@ import com.google.gson.JsonNull; import com.google.gson.JsonObject; import com.google.gson.JsonParser; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.source.extractor.utils.InputStreamCSVReader; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.source.extractor.utils.InputStreamCSVReader; public class CsvToJsonConverter extends Converter<String, JsonArray, String, JsonObject> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java index 95e7c51..f33dae7 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.converter.csv; +package org.apache.gobblin.converter.csv; import java.util.Iterator; import java.util.List; @@ -31,11 +31,11 @@ import com.google.gson.JsonNull; import com.google.gson.JsonObject; import com.google.gson.JsonParser; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; /** * CsvToJsonConverterV2 accepts already deserialized (parsed) CSV row, String[], where you can use http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java index b0eb533..b38ca92 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.filter; +package org.apache.gobblin.converter.filter; import java.io.IOException; import java.util.Iterator; @@ -31,13 +31,13 @@ import com.google.common.base.Preconditions; import com.google.common.base.Splitter; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.AvroToAvroConverterBase; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.util.AvroUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.AvroToAvroConverterBase; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.util.AvroUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java index d3fd8b2..a67cee0 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java @@ -15,23 +15,23 @@ * limitations under the License. */ -package gobblin.converter.filter; +package org.apache.gobblin.converter.filter; -import gobblin.converter.AvroToAvroConverterBase; -import gobblin.converter.Converter; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.converter.AvroToAvroConverterBase; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.converter.EmptyIterable; -import gobblin.util.AvroUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.EmptyIterable; +import org.apache.gobblin.util.AvroUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java index fd8a332..ff5cc10 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.converter.http; +package org.apache.gobblin.converter.http; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; @@ -27,11 +27,11 @@ import com.typesafe.config.ConfigParseOptions; import com.typesafe.config.ConfigRenderOptions; import com.typesafe.config.ConfigSyntax; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; /** * Converts Avro to RestJsonEntry. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java index 65d8e07..92f9d1b 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.converter.http; +package org.apache.gobblin.converter.http; import com.google.common.base.Optional; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java index e315ed1..5cb6951 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.initializer; +package org.apache.gobblin.converter.initializer; import java.util.List; @@ -23,11 +23,11 @@ import com.google.common.base.Preconditions; import com.google.common.base.Splitter; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.converter.Converter; -import gobblin.util.ForkOperatorUtils; -import gobblin.source.workunit.WorkUnitStream; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.source.workunit.WorkUnitStream; public class ConverterInitializerFactory { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java index 09881e9..14ac3e1 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.converter.initializer; +package org.apache.gobblin.converter.initializer; import java.util.List; import lombok.ToString; -import gobblin.initializer.Initializer; -import gobblin.initializer.MultiInitializer; +import org.apache.gobblin.initializer.Initializer; +import org.apache.gobblin.initializer.MultiInitializer; @ToString http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java index b9ba6b4..c73e58f 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.converter.json; +package org.apache.gobblin.converter.json; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; import java.io.IOException; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java index 6dbce40..f8b957b 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.converter.json; +package org.apache.gobblin.converter.json; import com.google.common.collect.Lists; import com.google.gson.Gson; import com.google.gson.JsonObject; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java index 39f1897..f5703f6 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.converter.objectstore; +package org.apache.gobblin.converter.objectstore; -import gobblin.annotation.Alpha; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.SchemaConversionException; -import gobblin.writer.objectstore.ObjectStoreOperation; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.writer.objectstore.ObjectStoreOperation; /** * A converter of {@link ObjectStoreOperation}s. The output record of any subclasses is of type {@link ObjectStoreOperation} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java index 500b2ac..9dc0d65 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.converter.objectstore; +package org.apache.gobblin.converter.objectstore; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; @@ -27,13 +27,13 @@ import com.google.common.base.Preconditions; import com.google.common.primitives.Ints; import com.google.common.primitives.Longs; -import gobblin.annotation.Alpha; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.util.AvroUtils; -import gobblin.writer.objectstore.ObjectStoreDeleteOperation; -import gobblin.writer.objectstore.ObjectStoreOperationBuilder; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.util.AvroUtils; +import org.apache.gobblin.writer.objectstore.ObjectStoreDeleteOperation; +import org.apache.gobblin.writer.objectstore.ObjectStoreOperationBuilder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java index 2913aaa..7e52991 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.serde; +package org.apache.gobblin.converter.serde; import java.io.IOException; @@ -38,13 +38,13 @@ import com.google.common.base.Throwables; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.hive.HiveSerDeWrapper; -import gobblin.instrumented.converter.InstrumentedConverter; -import gobblin.util.HadoopUtils; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.hive.HiveSerDeWrapper; +import org.apache.gobblin.instrumented.converter.InstrumentedConverter; +import org.apache.gobblin.util.HadoopUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java index db21feb..a66262f 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.converter.string; +package org.apache.gobblin.converter.string; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java index 36b5bd0..fe65c7b 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.string; +package org.apache.gobblin.converter.string; import java.util.regex.Matcher; import java.util.regex.Pattern; @@ -23,14 +23,14 @@ import java.util.regex.Pattern; import com.google.common.base.Optional; import com.google.common.base.Strings; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.EmptyIterable; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.EmptyIterable; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.util.ForkOperatorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java index 66f1e6c..03b7578 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.converter.string; +package org.apache.gobblin.converter.string; import com.google.common.base.Preconditions; import com.google.common.base.Splitter; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.util.ForkOperatorUtils; /** * Implementation of {@link Converter} that splits a string based on a delimiter specified by http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java index 1c7cefe..4880834 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package gobblin.converter.string; +package org.apache.gobblin.converter.string; import java.util.List; import com.google.common.base.Preconditions; import com.google.common.base.Splitter; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.util.ForkOperatorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java index dc3b467..b1a4ae0 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.converter.string; +package org.apache.gobblin.converter.string; import com.google.common.base.Charsets; import com.google.common.collect.Lists; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java index a66a196..0b11869 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.converter.string; +package org.apache.gobblin.converter.string; import org.apache.hadoop.io.Text; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java b/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java index 9a867f7..84d2e72 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; import org.apache.avro.generic.GenericData; import org.apache.avro.generic.GenericRecord; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java b/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java index ed3b205..fb80a52 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; import org.apache.avro.Schema;
