You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:52:50 UTC
[32/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
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;
/**