http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigStoreTest.java ---------------------------------------------------------------------- diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigStoreTest.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigStoreTest.java index f1760de..739051d 100644 --- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigStoreTest.java +++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigStoreTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.config.store.hdfs; +package org.apache.gobblin.config.store.hdfs; import java.io.BufferedWriter; import java.io.File; @@ -40,13 +40,13 @@ import com.google.common.base.Optional; import com.google.common.collect.ImmutableList; import com.typesafe.config.Config; -import gobblin.config.common.impl.SingleLinkedListConfigKeyPath; -import gobblin.config.store.api.ConfigKeyPath; -import gobblin.config.store.api.ConfigStoreCreationException; -import gobblin.config.store.deploy.ClasspathConfigSource; -import gobblin.config.store.deploy.FsDeploymentConfig; -import gobblin.util.ConfigUtils; -import gobblin.util.PathUtils; +import org.apache.gobblin.config.common.impl.SingleLinkedListConfigKeyPath; +import org.apache.gobblin.config.store.api.ConfigKeyPath; +import org.apache.gobblin.config.store.api.ConfigStoreCreationException; +import org.apache.gobblin.config.store.deploy.ClasspathConfigSource; +import org.apache.gobblin.config.store.deploy.FsDeploymentConfig; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PathUtils; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigureStoreFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigureStoreFactoryTest.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigureStoreFactoryTest.java index 24164ed..3149b5c 100644 --- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigureStoreFactoryTest.java +++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHdfsConfigureStoreFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.config.store.hdfs; +package org.apache.gobblin.config.store.hdfs; import java.io.IOException; import java.net.URI; @@ -31,7 +31,7 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.config.store.api.ConfigStoreCreationException; +import org.apache.gobblin.config.store.api.ConfigStoreCreationException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java b/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java index b922440..8787b2e 100644 --- a/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java +++ b/gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java @@ -10,7 +10,7 @@ * CONDITIONS OF ANY KIND, either express or implied. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Properties; @@ -37,9 +37,9 @@ import com.google.common.base.Optional; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.source.extractor.DefaultCheckpointableWatermark; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.util.ExecutorsUtils; @Warmup(iterations = 3) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java b/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java index badfac4..03abc5b 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/async/Callback.java @@ -1,4 +1,4 @@ -package gobblin.async; +package org.apache.gobblin.async; public interface Callback<T> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionConfigParser.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionConfigParser.java b/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionConfigParser.java index 548e062..03083a6 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionConfigParser.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionConfigParser.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compression; +package org.apache.gobblin.compression; import java.util.Map; import com.google.common.collect.ImmutableMap; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.ForkOperatorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionFactory.java b/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionFactory.java index 074187a..0f89e5d 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionFactory.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/compression/CompressionFactory.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compression; +package org.apache.gobblin.compression; import java.util.Map; -import gobblin.annotation.Alpha; -import gobblin.codec.GzipCodec; -import gobblin.codec.StreamCodec; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.codec.GzipCodec; +import org.apache.gobblin.codec.StreamCodec; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AsyncConverter1to1.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AsyncConverter1to1.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AsyncConverter1to1.java index 90b05a6..7eb1563 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AsyncConverter1to1.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AsyncConverter1to1.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.util.concurrent.CompletableFuture; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.stream.ControlMessage; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.stream.RecordEnvelope; -import gobblin.stream.StreamEntity; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.stream.ControlMessage; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.stream.StreamEntity; import io.reactivex.Flowable; import io.reactivex.Single; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AvroToAvroConverterBase.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AvroToAvroConverterBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AvroToAvroConverterBase.java index 654553a..215a7c4 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AvroToAvroConverterBase.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/AvroToAvroConverterBase.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/converter/IdentityConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/IdentityConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/IdentityConverter.java index 31ce071..95ae5bd 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/IdentityConverter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/IdentityConverter.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** * Implementation of {@link Converter} that returns the inputSchema unmodified and each inputRecord unmodified http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java index e6074aa..db1c9d8 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SamplingConverter.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.util.Collections; @@ -28,8 +28,8 @@ import com.typesafe.config.Config; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.WorkUnitState; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SingleRecordIterable.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SingleRecordIterable.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SingleRecordIterable.java index 76d2e30..61fa5b3 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SingleRecordIterable.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/SingleRecordIterable.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/main/java/org/apache/gobblin/converter/ToAvroConverterBase.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/ToAvroConverterBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/ToAvroConverterBase.java index 46837bb..ced8d0f 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/ToAvroConverterBase.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/ToAvroConverterBase.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroProjectionConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroProjectionConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroProjectionConverter.java index cf550ab..6961ab5 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroProjectionConverter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroProjectionConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.filter; +package org.apache.gobblin.converter.filter; import java.io.IOException; @@ -24,14 +24,14 @@ import org.apache.avro.generic.GenericRecord; import com.google.common.base.Optional; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.AvroToAvroConverterBase; -import gobblin.converter.Converter; -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.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; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemover.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemover.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemover.java index e7ff5ba..d681619 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemover.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemover.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter.filter; +package org.apache.gobblin.converter.filter; import java.util.List; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java index c1b0e53..a160883 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.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.ArrayList; @@ -35,14 +35,14 @@ import com.google.common.collect.BiMap; import com.google.common.collect.HashBiMap; import com.typesafe.config.Config; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.AvroToAvroConverterBase; -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.AvroToAvroConverterBase; +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; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/CredentialStoreFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/CredentialStoreFactory.java b/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/CredentialStoreFactory.java index 78331a8..2c91542 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/CredentialStoreFactory.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/CredentialStoreFactory.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.ServiceLoader; @@ -22,7 +22,7 @@ import java.util.ServiceLoader; import lombok.Synchronized; import lombok.extern.slf4j.Slf4j; -import gobblin.codec.StreamCodec; +import org.apache.gobblin.codec.StreamCodec; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionConfigParser.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionConfigParser.java b/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionConfigParser.java index 6e8fa64..324365a 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionConfigParser.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionConfigParser.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.HashMap; import java.util.Iterator; @@ -23,11 +23,11 @@ import java.util.Properties; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.password.PasswordManager; -import gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.password.PasswordManager; +import org.apache.gobblin.util.ForkOperatorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java b/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java index fc862f2..ff31673 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.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.ServiceLoader; @@ -22,7 +22,7 @@ import java.util.ServiceLoader; import lombok.Synchronized; import lombok.extern.slf4j.Slf4j; -import gobblin.codec.StreamCodec; +import org.apache.gobblin.codec.StreamCodec; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/GobblinMetricsKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/GobblinMetricsKeys.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/GobblinMetricsKeys.java index cb553f3..baf5fcb 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/GobblinMetricsKeys.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/GobblinMetricsKeys.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.instrumented; +package org.apache.gobblin.instrumented; -import gobblin.Constructs; +import org.apache.gobblin.Constructs; /** * Shared constants related to gobblin metrics http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java index 73a093f..e9292b1 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.instrumented; +package org.apache.gobblin.instrumented; import java.util.List; import javax.annotation.Nonnull; -import gobblin.configuration.State; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java index 152e6f8..9b149e8 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented; +package org.apache.gobblin.instrumented; import java.io.Closeable; import java.io.IOException; @@ -41,19 +41,19 @@ import com.google.common.collect.Iterables; import com.google.common.collect.Lists; import com.google.common.io.Closer; -import gobblin.Constructs; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.converter.Converter; -import gobblin.fork.ForkOperator; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.GobblinMetricsRegistry; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.qualitychecker.row.RowLevelPolicy; -import gobblin.source.extractor.Extractor; -import gobblin.util.DecoratorUtils; -import gobblin.writer.DataWriter; +import org.apache.gobblin.Constructs; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.fork.ForkOperator; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.GobblinMetricsRegistry; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicy; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.util.DecoratorUtils; +import org.apache.gobblin.writer.DataWriter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java index 074965b..aaf32ed 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.instrumented.converter; +package org.apache.gobblin.instrumented.converter; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.DataConversionException; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.DataConversionException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java index 842f1fe..e42d401 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented.converter; +package org.apache.gobblin.instrumented.converter; import java.io.Closeable; import java.io.IOException; @@ -31,16 +31,16 @@ import com.google.common.collect.Iterables; import com.google.common.collect.Lists; import com.google.common.io.Closer; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.instrumented.Instrumentable; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.MetricNames; -import gobblin.metrics.Tag; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.metrics.Tag; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java index 8116e5c..06c857b 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java @@ -15,21 +15,21 @@ * limitations under the License. */ -package gobblin.instrumented.converter; +package org.apache.gobblin.instrumented.converter; import java.io.IOException; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.records.ControlMessageHandler; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.util.Decorator; -import gobblin.util.DecoratorUtils; +import org.apache.gobblin.configuration.State; +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.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.records.ControlMessageHandler; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.util.Decorator; +import org.apache.gobblin.util.DecoratorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java index f22b3ab..aeabd4b 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.instrumented.extractor; +package org.apache.gobblin.instrumented.extractor; import java.io.IOException; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.stream.RecordEnvelope; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.DataRecordException; +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/instrumented/extractor/InstrumentedExtractorBase.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java index 7731d42..cb6ca2e 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented.extractor; +package org.apache.gobblin.instrumented.extractor; import java.io.Closeable; import java.io.IOException; @@ -30,20 +30,20 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.google.common.io.Closer; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.instrumented.Instrumentable; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.MetricNames; -import gobblin.metrics.Tag; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; -import gobblin.stream.RecordEnvelope; -import gobblin.stream.StreamEntity; -import gobblin.util.FinalState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.metrics.Tag; +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; +import org.apache.gobblin.stream.StreamEntity; +import org.apache.gobblin.util.FinalState; import edu.umd.cs.findbugs.annotations.SuppressWarnings; import io.reactivex.Emitter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java index 52bfb14..4af7805 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java @@ -15,24 +15,24 @@ * limitations under the License. */ -package gobblin.instrumented.extractor; +package org.apache.gobblin.instrumented.extractor; import java.io.IOException; import java.util.concurrent.atomic.AtomicBoolean; import com.google.common.base.Optional; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; -import gobblin.stream.RecordEnvelope; -import gobblin.util.Decorator; -import gobblin.util.DecoratorUtils; -import gobblin.util.FinalState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +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; +import org.apache.gobblin.util.Decorator; +import org.apache.gobblin.util.DecoratorUtils; +import org.apache.gobblin.util.FinalState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java index dc3df0a..9ce4c7f 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.instrumented.fork; +package org.apache.gobblin.instrumented.fork; import java.util.List; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java index cbd8f52..ca00aea 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.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.List; @@ -28,15 +28,15 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.google.common.io.Closer; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.fork.ForkOperator; -import gobblin.instrumented.Instrumentable; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.MetricNames; -import gobblin.metrics.Tag; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.fork.ForkOperator; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.metrics.Tag; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java index 300a536..8436b20 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java @@ -15,18 +15,18 @@ * limitations under the License. */ -package gobblin.instrumented.fork; +package org.apache.gobblin.instrumented.fork; import java.util.List; import com.google.common.base.Optional; -import gobblin.configuration.WorkUnitState; -import gobblin.fork.ForkOperator; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.util.Decorator; -import gobblin.util.DecoratorUtils; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.fork.ForkOperator; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.util.Decorator; +import org.apache.gobblin.util.DecoratorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java index 9262108..27b34cf 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.instrumented.qualitychecker; +package org.apache.gobblin.instrumented.qualitychecker; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java index 4d4d578..b48332f 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented.qualitychecker; +package org.apache.gobblin.instrumented.qualitychecker; import java.io.Closeable; import java.io.IOException; @@ -29,14 +29,14 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.google.common.io.Closer; -import gobblin.configuration.State; -import gobblin.instrumented.Instrumentable; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.MetricNames; -import gobblin.metrics.Tag; -import gobblin.qualitychecker.row.RowLevelPolicy; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicy; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java index 1dc1f9d..ddf02fb 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java @@ -15,18 +15,18 @@ * limitations under the License. */ -package gobblin.instrumented.qualitychecker; +package org.apache.gobblin.instrumented.qualitychecker; import java.io.IOException; import com.google.common.base.Optional; -import gobblin.configuration.State; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.qualitychecker.row.RowLevelPolicy; -import gobblin.util.Decorator; -import gobblin.util.DecoratorUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicy; +import org.apache.gobblin.util.Decorator; +import org.apache.gobblin.util.DecoratorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java index e8a30eb..f4ae8e7 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.instrumented.writer; +package org.apache.gobblin.instrumented.writer; import java.io.IOException; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java index 3c32e98..99e0a5f 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented.writer; +package org.apache.gobblin.instrumented.writer; import java.io.Closeable; import java.io.IOException; @@ -33,16 +33,16 @@ import com.google.common.io.Closer; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.State; -import gobblin.instrumented.Instrumentable; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.MetricNames; -import gobblin.metrics.Tag; -import gobblin.util.ExecutorsUtils; -import gobblin.util.FinalState; -import gobblin.writer.DataWriter; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.FinalState; +import org.apache.gobblin.writer.DataWriter; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java index 3c63a8b..2f6ff8b 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.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,17 +23,17 @@ import java.util.Map; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.configuration.State; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.records.ControlMessageHandler; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.stream.RecordEnvelope; -import gobblin.util.Decorator; -import gobblin.util.DecoratorUtils; -import gobblin.util.FinalState; -import gobblin.writer.DataWriter; -import gobblin.writer.WatermarkAwareWriter; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.records.ControlMessageHandler; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.util.Decorator; +import org.apache.gobblin.util.DecoratorUtils; +import org.apache.gobblin.util.FinalState; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.WatermarkAwareWriter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.java index 16e61b5..592471a 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.instrumented.writer; +package org.apache.gobblin.instrumented.writer; import java.util.List; @@ -24,9 +24,9 @@ import org.apache.avro.generic.GenericRecord; import com.google.common.collect.ImmutableList; -import gobblin.configuration.State; -import gobblin.metrics.Tag; -import gobblin.writer.DataWriter; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.writer.DataWriter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java index 197ce13..c7da8f1 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/DefaultCheckpointableWatermark.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import com.google.gson.Gson; import com.google.gson.GsonBuilder; @@ -25,7 +25,7 @@ import com.google.gson.JsonElement; import lombok.EqualsAndHashCode; -import gobblin.util.io.GsonInterfaceAdapter; +import org.apache.gobblin.util.io.GsonInterfaceAdapter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java index d1744ac..2546f00 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import java.util.Properties; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/WorkUnitRetryPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/WorkUnitRetryPolicy.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/WorkUnitRetryPolicy.java index 12e0744..3bd17d1 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/WorkUnitRetryPolicy.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/WorkUnitRetryPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import com.google.common.base.Preconditions; import com.google.common.base.Strings; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java index 57e7348..8eaadc1 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract; +package org.apache.gobblin.source.extractor.extract; import java.util.List; @@ -23,16 +23,16 @@ import com.google.common.collect.ImmutableList; import com.google.common.collect.Iterables; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.Source; -import gobblin.source.extractor.JobCommitPolicy; -import gobblin.source.extractor.WorkUnitRetryPolicy; -import gobblin.source.workunit.ExtractFactory; -import gobblin.source.workunit.WorkUnit; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.Extract.TableType; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.JobCommitPolicy; +import org.apache.gobblin.source.extractor.WorkUnitRetryPolicy; +import org.apache.gobblin.source.workunit.ExtractFactory; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.Extract.TableType; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java index 8dd2f6d..4b31938 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.source.extractor.extract; +package org.apache.gobblin.source.extractor.extract; -import gobblin.configuration.WorkUnitState; -import gobblin.instrumented.extractor.InstrumentedExtractor; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.instrumented.extractor.InstrumentedExtractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java index 7f9ebaf..840cb66 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.source.extractor.extract; +package org.apache.gobblin.source.extractor.extract; -import gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.SourceState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/LongWatermark.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/LongWatermark.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/LongWatermark.java index 36dd2f8..bc82965 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/LongWatermark.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/LongWatermark.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract; +package org.apache.gobblin.source.extractor.extract; import java.math.RoundingMode; @@ -25,8 +25,8 @@ import com.google.common.primitives.Longs; import com.google.gson.Gson; import com.google.gson.JsonElement; -import gobblin.source.extractor.ComparableWatermark; -import gobblin.source.extractor.Watermark; +import org.apache.gobblin.source.extractor.ComparableWatermark; +import org.apache.gobblin.source.extractor.Watermark; import lombok.EqualsAndHashCode; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java index 65b281c..d06c146 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/limiter/LimiterConfigurationKeys.java @@ -1,4 +1,4 @@ -package gobblin.source.extractor.limiter; +package org.apache.gobblin.source.extractor.limiter; public class LimiterConfigurationKeys { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java index 8df2fe6..e33f562 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToJsonConverter.java @@ -17,18 +17,18 @@ * under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.util.Collections; import com.google.gson.Gson; import com.google.gson.JsonElement; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.util.io.GsonInterfaceAdapter; +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.io.GsonInterfaceAdapter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java index 239c600..b7f5f97 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/test/AnyToStringConverter.java @@ -17,13 +17,13 @@ * under the License. */ -package gobblin.test; +package org.apache.gobblin.test; -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-base/src/main/java/org/apache/gobblin/test/SequentialTestSource.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/test/SequentialTestSource.java b/gobblin-core-base/src/main/java/org/apache/gobblin/test/SequentialTestSource.java index b29b9a9..12ba1f2 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/test/SequentialTestSource.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/test/SequentialTestSource.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.io.IOException; import java.util.Collections; @@ -32,22 +32,22 @@ import com.typesafe.config.ConfigFactory; import avro.shaded.com.google.common.base.Throwables; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.Source; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.DefaultCheckpointableWatermark; -import gobblin.source.extractor.Extractor; -import gobblin.stream.RecordEnvelope; -import gobblin.source.extractor.StreamingExtractor; -import gobblin.source.extractor.WatermarkInterval; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.ExtractFactory; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ConfigUtils; -import gobblin.writer.WatermarkStorage; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.extractor.StreamingExtractor; +import org.apache.gobblin.source.extractor.WatermarkInterval; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.ExtractFactory; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.writer.WatermarkStorage; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java b/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java index bcbd50e..b52d9e4 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/test/TestRecord.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java index 178927f..8e28ea8 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java @@ -17,11 +17,11 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; -import gobblin.ack.Ackable; -import gobblin.annotation.Alpha; -import gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.ack.Ackable; +import org.apache.gobblin.annotation.Alpha; +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/AcknowledgableWatermark.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java index 848fbc4..165783d 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java @@ -17,12 +17,12 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.concurrent.atomic.AtomicInteger; -import gobblin.ack.Ackable; -import gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.ack.Ackable; +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/AsyncDataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncDataWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncDataWriter.java index 2766035..04247ed 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncDataWriter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncDataWriter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.io.IOException; @@ -23,7 +23,7 @@ import java.util.concurrent.Future; import javax.annotation.Nullable; -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/AsyncWriterManager.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java index 72c9fbb..17a5530 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.io.IOException; @@ -47,20 +47,20 @@ import javax.annotation.Nonnull; import lombok.Getter; import lombok.Setter; -import gobblin.ack.Ackable; -import gobblin.configuration.State; -import gobblin.instrumented.Instrumentable; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.MetricNames; -import gobblin.metrics.Tag; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.stream.RecordEnvelope; -import gobblin.util.ConfigUtils; -import gobblin.util.ExecutorsUtils; -import gobblin.util.FinalState; -import gobblin.writer.exception.NonTransientException; +import org.apache.gobblin.ack.Ackable; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.FinalState; +import org.apache.gobblin.writer.exception.NonTransientException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java index 12a99c0..f209c98 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.List; import java.util.ArrayList; import java.util.concurrent.CountDownLatch; @@ -27,7 +27,7 @@ import java.util.concurrent.atomic.AtomicInteger; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** @@ -56,7 +56,7 @@ public abstract class Batch<D>{ private static final Logger LOG = LoggerFactory.getLogger(Batch.class); public Batch () { - recordCount = 0; + recordCount = 0; thunks = new ArrayList<>(); id = identifier.incrementAndGet(); } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java index 47e4f93..80c1652 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAccumulator.java @@ -1,4 +1,4 @@ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.util.concurrent.CountDownLatch; @@ -8,7 +8,7 @@ import java.util.concurrent.atomic.AtomicInteger; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -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/BatchAsyncDataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAsyncDataWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAsyncDataWriter.java index 16beb76..8bf7685 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAsyncDataWriter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BatchAsyncDataWriter.java @@ -17,14 +17,14 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.io.IOException; import java.util.concurrent.Future; import javax.annotation.Nullable; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** * An interface for implementing Async Writers for Gobblin. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java index ad577da..141217e 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.io.IOException; @@ -31,7 +31,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.annotation.Nullable; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** * An async data writer which can achieve the buffering and batching capability. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BytesBoundedBatch.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BytesBoundedBatch.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BytesBoundedBatch.java index 6557c46..30ceee7 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BytesBoundedBatch.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/BytesBoundedBatch.java @@ -17,8 +17,8 @@ * under the License. */ -package gobblin.writer; -import gobblin.annotation.Alpha; +package org.apache.gobblin.writer; +import org.apache.gobblin.annotation.Alpha; import java.util.LinkedList; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FineGrainedWatermarkTracker.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FineGrainedWatermarkTracker.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FineGrainedWatermarkTracker.java index dc03823..f11c7f3 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FineGrainedWatermarkTracker.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FineGrainedWatermarkTracker.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.io.IOException; @@ -45,16 +45,16 @@ import javax.annotation.Nonnull; import javax.annotation.concurrent.NotThreadSafe; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.State; -import gobblin.instrumented.Instrumentable; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.MetricNames; -import gobblin.metrics.Tag; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.util.ConfigUtils; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.MetricNames; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.util.ConfigUtils; +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/FutureWrappedWriteCallback.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java index 12af94c..eb1d803 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.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/GenericWriteResponse.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponse.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponse.java index afe796b..99508ed 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponse.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponse.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; /** * A generic write response to wrap responses from other systems. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponseWrapper.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponseWrapper.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponseWrapper.java index b9994ad..0f0845b 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponseWrapper.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/GenericWriteResponseWrapper.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; public class GenericWriteResponseWrapper<T> implements WriteResponseMapper<T> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/LastWatermarkTracker.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/LastWatermarkTracker.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/LastWatermarkTracker.java index 6137813..1bdf52a 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/LastWatermarkTracker.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/LastWatermarkTracker.java @@ -17,14 +17,14 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.Collections; import java.util.HashMap; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; -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/MultiWriterWatermarkManager.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkManager.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkManager.java index 380bf5d..328d893 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkManager.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkManager.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.ArrayList; @@ -40,8 +40,8 @@ import com.google.common.base.Preconditions; import lombok.Getter; import lombok.ToString; -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/MultiWriterWatermarkTracker.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkTracker.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkTracker.java index 42e5a37..86f6a56 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkTracker.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkTracker.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.HashMap; import java.util.Map; @@ -27,7 +27,7 @@ import java.util.concurrent.ConcurrentHashMap; import com.google.common.base.Optional; -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/PartitionAwareDataWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java index 553b5ac..0ed9110 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; @@ -24,7 +24,7 @@ import com.google.common.base.Optional; import lombok.extern.slf4j.Slf4j; -import gobblin.writer.partitioner.WriterPartitioner; +import org.apache.gobblin.writer.partitioner.WriterPartitioner; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordFuture.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordFuture.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordFuture.java index 25b3945..e560abe 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordFuture.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordFuture.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Future; @@ -25,7 +25,7 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.concurrent.ExecutionException; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** * A future object generated after a record was inserted into a batch http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordMetadata.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordMetadata.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordMetadata.java index 23a0b88..95bbef2 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordMetadata.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/RecordMetadata.java @@ -17,9 +17,9 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; @Alpha http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SequentialBasedBatchAccumulator.java ---------------------------------------------------------------------- diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SequentialBasedBatchAccumulator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SequentialBasedBatchAccumulator.java index 3c9da3b..dfa1672 100644 --- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SequentialBasedBatchAccumulator.java +++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SequentialBasedBatchAccumulator.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.LinkedList; import java.util.ArrayList; @@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory; import com.google.common.util.concurrent.Futures; import com.typesafe.config.Config; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ConfigUtils; /**
