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:46 UTC
[28/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-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
index f5cb017..d915730 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import java.io.IOException;
import java.util.Map;
@@ -36,18 +36,18 @@ import com.google.common.io.Closer;
import lombok.extern.slf4j.Slf4j;
-import gobblin.commit.SpeculativeAttemptAwareConstruct;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.instrumented.writer.InstrumentedDataWriterDecorator;
-import gobblin.instrumented.writer.InstrumentedPartitionedDataWriterDecorator;
-import gobblin.records.ControlMessageHandler;
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.stream.ControlMessage;
-import gobblin.stream.RecordEnvelope;
-import gobblin.util.AvroUtils;
-import gobblin.util.FinalState;
-import gobblin.writer.partitioner.WriterPartitioner;
+import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.writer.InstrumentedDataWriterDecorator;
+import org.apache.gobblin.instrumented.writer.InstrumentedPartitionedDataWriterDecorator;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.FinalState;
+import org.apache.gobblin.writer.partitioner.WriterPartitioner;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java
index 091e3e1..0a6a88d 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import com.github.rholder.retry.RetryerBuilder;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java
index 2fc24b9..2c04003 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import java.io.IOException;
import java.util.concurrent.Callable;
@@ -35,14 +35,14 @@ import com.github.rholder.retry.WaitStrategies;
import com.google.common.base.Optional;
import com.google.common.base.Predicate;
-import gobblin.commit.SpeculativeAttemptAwareConstruct;
-import gobblin.configuration.State;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.records.ControlMessageHandler;
-import gobblin.stream.RecordEnvelope;
-import gobblin.util.FinalState;
-import gobblin.writer.exception.NonTransientException;
+import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.util.FinalState;
+import org.apache.gobblin.writer.exception.NonTransientException;
/**
* Retry writer follows decorator pattern that retries on inner writer's failure.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java
index 542db50..878d189 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import org.apache.avro.Schema;
import org.apache.hadoop.fs.Path;
-import gobblin.configuration.State;
-import gobblin.writer.partitioner.SchemaBasedWriterPartitioner;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.writer.partitioner.SchemaBasedWriterPartitioner;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java
index ca3d1d8..4a96904 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import java.io.IOException;
import java.io.OutputStream;
@@ -29,8 +29,8 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.primitives.Longs;
-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/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
index 82043e1..c81daa7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import java.io.IOException;
import java.util.ArrayList;
@@ -24,11 +24,11 @@ import java.util.Map;
import com.google.common.base.Preconditions;
-import gobblin.codec.StreamCodec;
-import gobblin.compression.CompressionConfigParser;
-import gobblin.compression.CompressionFactory;
-import gobblin.crypto.EncryptionConfigParser;
-import gobblin.crypto.EncryptionFactory;
+import org.apache.gobblin.codec.StreamCodec;
+import org.apache.gobblin.compression.CompressionConfigParser;
+import org.apache.gobblin.compression.CompressionFactory;
+import org.apache.gobblin.crypto.EncryptionConfigParser;
+import org.apache.gobblin.crypto.EncryptionFactory;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java
index da19663..eccd69f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
@@ -27,15 +27,15 @@ import com.github.rholder.retry.RetryerBuilder;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import gobblin.stream.RecordEnvelope;
-import gobblin.util.Decorator;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.RateBasedLimiter;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.util.FinalState;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.util.Decorator;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.RateBasedLimiter;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.util.FinalState;
/**
* Throttle writer follows decorator pattern that throttles inner writer by either QPS or by bytes.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java
index 3a339e3..1e2e086 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
import java.net.URI;
@@ -41,8 +41,8 @@ import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
-import gobblin.instrumented.writer.InstrumentedDataWriter;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.instrumented.writer.InstrumentedDataWriter;
+import org.apache.gobblin.util.ExecutorsUtils;
/**
* Base class for HTTP writers. Defines the main extension points for different implementations.
@@ -103,7 +103,7 @@ public abstract class AbstractHttpWriter<D> extends InstrumentedDataWriter<D> im
this.client.close();
ExecutorsUtils.shutdownExecutorService(this.singleThreadPool, Optional.of(log));
}
-
+
/**
* {@inheritDoc}
*/
@@ -112,7 +112,7 @@ public abstract class AbstractHttpWriter<D> extends InstrumentedDataWriter<D> im
cleanup();
super.close();
}
-
+
/**
* {@inheritDoc}
*/
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java
index 2bd9ade..db6d63b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.net.URI;
import java.net.URISyntaxException;
@@ -34,11 +34,11 @@ import com.google.common.collect.ImmutableMap;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.config.ConfigBuilder;
-import gobblin.configuration.State;
-import gobblin.http.HttpClientConfiguratorLoader;
-import gobblin.writer.Destination;
-import gobblin.writer.FluentDataWriterBuilder;
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.http.HttpClientConfiguratorLoader;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.FluentDataWriterBuilder;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java
index 85c937d..d42ef9a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java
index cce5f8a..644b052 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
import java.net.MalformedURLException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java
index 5593e21..efaff72 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java
@@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriter;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java
index e16cffc..8185d65 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
import java.net.URI;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java
index dba2a1e..1531e13 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
import java.net.URI;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java
index dcad4c4..583e7aa 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import org.apache.http.HttpHeaders;
import org.apache.http.client.methods.HttpUriRequest;
@@ -25,7 +25,7 @@ import org.apache.http.entity.StringEntity;
import com.google.common.base.Optional;
import com.google.gson.JsonObject;
-import gobblin.converter.http.RestEntry;
+import org.apache.gobblin.converter.http.RestEntry;
/**
* Writes via Restful API that accepts JSON as a body
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java
index f42a3f2..c3e61fd 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java
@@ -14,14 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
import com.google.gson.JsonObject;
-import gobblin.converter.http.RestEntry;
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.writer.DataWriter;
/**
* Builder that builds RestJsonWriter
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java
index e5e8385..3c49f09 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import org.apache.http.HttpHeaders;
import org.apache.http.client.methods.HttpUriRequest;
@@ -24,7 +24,7 @@ import org.apache.http.entity.StringEntity;
import com.google.common.base.Optional;
-import gobblin.converter.http.RestEntry;
+import org.apache.gobblin.converter.http.RestEntry;
/**
* Writes via RESTful API that accepts plain text as a body and resource path from RestEntry
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java
index 9d2b592..4a0c97b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java
@@ -14,12 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
-import gobblin.converter.http.RestEntry;
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.writer.DataWriter;
public class RestWriterBuilder extends AbstractHttpWriterBuilder<Void, RestEntry<String>, RestWriterBuilder> {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java
index 652f63e..c0ed056 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
import java.util.Properties;
@@ -26,11 +26,11 @@ import com.google.gson.JsonObject;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.converter.http.RestEntry;
-import gobblin.password.PasswordManager;
-import gobblin.writer.DataWriter;
-import gobblin.writer.http.SalesforceRestWriter.Operation;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.http.SalesforceRestWriter.Operation;
import lombok.AccessLevel;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java
index 8c55b38..239b38d 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
import java.net.URI;
@@ -47,8 +47,8 @@ import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
-import gobblin.converter.http.RestEntry;
-import gobblin.writer.exception.NonTransientException;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.writer.exception.NonTransientException;
/**
* Writes to Salesforce via RESTful API, supporting INSERT_ONLY_NOT_EXIST, and UPSERT.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java
index cd93221..36e10ca 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java
index 30ad36e..7b3ba3e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.writer.initializer;
+package org.apache.gobblin.writer.initializer;
-import gobblin.initializer.Initializer;
-import gobblin.initializer.MultiInitializer;
+import org.apache.gobblin.initializer.Initializer;
+import org.apache.gobblin.initializer.MultiInitializer;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java
index bb725cc..8585cb2 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.writer.initializer;
+package org.apache.gobblin.writer.initializer;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.source.workunit.WorkUnitStream;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.workunit.WorkUnitStream;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.writer.DataWriterBuilder;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java
index b5b071a..56601bb 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
import java.io.IOException;
import java.io.InputStream;
@@ -23,8 +23,8 @@ import javax.annotation.Nonnull;
import com.typesafe.config.Config;
-import gobblin.annotation.Alpha;
-import gobblin.writer.objectstore.response.GetObjectResponse;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.writer.objectstore.response.GetObjectResponse;
/**
* A client interface to interact with an object store. Supports basic operations like put,delete and get.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java
index d1a7a75..f20d067 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
import java.io.IOException;
@@ -28,8 +28,8 @@ import com.google.common.base.Preconditions;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.annotation.Alpha;
-import gobblin.writer.objectstore.response.DeleteResponse;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.writer.objectstore.response.DeleteResponse;
/**
* An {@link ObjectStoreOperation} that deletes an object with <code>objectId</code> in the object store.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java
index a250754..8ddea35 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java
@@ -14,12 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
import java.io.IOException;
-import gobblin.annotation.Alpha;
-import gobblin.converter.objectstore.ObjectStoreConverter;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.converter.objectstore.ObjectStoreConverter;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java
index 71dd996..80ab72b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java
@@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
* Builder to build all types of {@link ObjectStoreOperation}s
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java
index f6cd07c..26e6fa7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
import java.io.IOException;
@@ -22,9 +22,9 @@ import lombok.Getter;
import com.codahale.metrics.Counter;
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.instrumented.writer.InstrumentedDataWriter;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.writer.InstrumentedDataWriter;
/**
* A writer to execute operations on a object in any object store. The record type of this writer is an {@link ObjectStoreOperation}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java
index a143600..5290a81 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.objectstore.response;
+package org.apache.gobblin.writer.objectstore.response;
import lombok.AllArgsConstructor;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java
index 15b7c41..93ba4e4 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.objectstore.response;
+package org.apache.gobblin.writer.objectstore.response;
import java.io.InputStream;
@@ -23,7 +23,7 @@ import lombok.Getter;
import com.typesafe.config.Config;
-import gobblin.writer.objectstore.ObjectStoreClient;
+import org.apache.gobblin.writer.objectstore.ObjectStoreClient;
/**
* The response of {@link ObjectStoreClient#getObject(String)} that holds an {@link InputStream} to the object and object
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java
index 9993056..cbd494c 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
import org.apache.avro.Schema;
import org.apache.avro.SchemaBuilder;
import org.apache.avro.generic.GenericData;
import org.apache.avro.generic.GenericRecord;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java
index 20109d2..54e5abc 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
import java.util.List;
@@ -23,10 +23,10 @@ import org.apache.avro.generic.GenericRecord;
import com.google.common.base.Optional;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.AvroUtils;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.ForkOperatorUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java
index 30a2dae..cf35f1e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
import java.util.Collections;
@@ -35,10 +35,10 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.base.Strings;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.DatePartitionType;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.DatePartitionType;
+import org.apache.gobblin.util.ForkOperatorUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java
index 8d708f8..4c4241f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
-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/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java
index 358e768..e9a4acd 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.test;
+package org.apache.gobblin.writer.test;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicLong;
@@ -22,12 +22,12 @@ import java.util.concurrent.atomic.AtomicLong;
import com.google.common.base.Optional;
import com.google.common.eventbus.EventBus;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.util.WriterUtils;
-import gobblin.writer.DataWriter;
-import gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.util.WriterUtils;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriterBuilder;
import lombok.Data;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java
index bc0e624..8c299d0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.test;
+package org.apache.gobblin.writer.test;
import java.io.Closeable;
import java.io.IOException;
@@ -34,7 +34,7 @@ import com.google.common.base.Predicates;
import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;
-import gobblin.writer.test.TestingEventBuses.Event;
+import org.apache.gobblin.writer.test.TestingEventBuses.Event;
import lombok.AllArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java
index 54247bb..c12a44c 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.writer.test;
+package org.apache.gobblin.writer.test;
import java.util.concurrent.ExecutionException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java b/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java
index 7ced0c1..d53effe 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java
@@ -1,4 +1,4 @@
-package gobblin.async;
+package org.apache.gobblin.async;
import java.util.Queue;
import java.util.concurrent.Callable;
@@ -10,7 +10,7 @@ import java.util.concurrent.Future;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.util.ExponentialBackoff;
+import org.apache.gobblin.util.ExponentialBackoff;
@Test
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java b/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java
index 4b33c76..e91bd99 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.commit;
+package org.apache.gobblin.commit;
import java.io.IOException;
@@ -27,7 +27,7 @@ import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java b/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java
index ecb8241..5d54e85 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java b/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java
index cd7eb74..1285737 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
-import gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.Extract;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
@@ -28,7 +28,7 @@ import java.io.IOException;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
public class WorkUnitStateTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java b/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java
index 09d9429..22684b2 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.configuration.workunit;
+package org.apache.gobblin.configuration.workunit;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
@@ -30,8 +30,8 @@ import org.testng.annotations.Test;
import com.google.common.io.Closer;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java
index b1ee227..0a36704 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.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/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java
index aed63d3..bcb423a 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.converter;
+package org.apache.gobblin.converter;
import java.util.List;
@@ -29,13 +29,13 @@ import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Lists;
import com.google.common.collect.Sets;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metrics.Metric;
-import gobblin.metrics.MetricReport;
-import gobblin.metrics.reporter.util.AvroBinarySerializer;
-import gobblin.metrics.reporter.util.AvroSerializer;
-import gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
-import gobblin.util.AvroUtils;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metrics.Metric;
+import org.apache.gobblin.metrics.MetricReport;
+import org.apache.gobblin.metrics.reporter.util.AvroBinarySerializer;
+import org.apache.gobblin.metrics.reporter.util.AvroSerializer;
+import org.apache.gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
+import org.apache.gobblin.util.AvroUtils;
public class GobblinMetricsPinotFlattenerConverterTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java
index f832589..89f0e94 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
import java.io.IOException;
import java.util.Iterator;
@@ -26,9 +26,9 @@ import org.apache.commons.io.IOUtils;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
public class AvroToBytesConverterTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java
index 6c8da1b..bcea977 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
import java.io.IOException;
import java.io.InputStream;
@@ -27,9 +27,9 @@ import org.apache.commons.io.IOUtils;
import org.junit.Assert;
import org.testng.annotations.Test;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
public class BytesToAvroConverterTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java
index 11413da..e109548 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java
@@ -1,4 +1,4 @@
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
import java.io.File;
import java.io.IOException;
@@ -13,10 +13,10 @@ import org.testng.annotations.Test;
import junit.framework.Assert;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.util.AvroUtils;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.util.AvroUtils;
@Test
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java
index cac3c68..558c1f6 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
import java.io.InputStreamReader;
import java.lang.reflect.Type;
@@ -38,10 +38,10 @@ import com.google.gson.Gson;
import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
import com.google.gson.reflect.TypeToken;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-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.workunit.Extract.TableType;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java
index 261c3a1..6d38f0d 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.converter.csv;
+package org.apache.gobblin.converter.csv;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
import java.io.IOException;
import java.io.InputStreamReader;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java
index 6f8c75b..009bcc7 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.converter.filter;
+package org.apache.gobblin.converter.filter;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.SchemaConversionException;
import org.apache.avro.Schema;
import org.skyscreamer.jsonassert.JSONAssert;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java
index 44e7374..f5c5981 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java
@@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.converter.http;
+package org.apache.gobblin.converter.http;
import java.io.File;
import java.io.IOException;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
import org.apache.avro.Schema;
import org.apache.avro.file.DataFileReader;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java
index 8e45847..c4e5034 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.converter.objectstore;
+package org.apache.gobblin.converter.objectstore;
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericData;
@@ -26,7 +26,7 @@ import com.google.common.collect.Iterables;
import com.google.common.primitives.Ints;
import com.google.common.primitives.Longs;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
public class ObjectStoreDeleteConverterTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java
index c187b0b..f7995ce 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java
@@ -16,13 +16,13 @@
* limitations under the License.
*/
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
import java.util.Iterator;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
import org.testng.Assert;
import org.testng.annotations.Test;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java
index 2c02868..9cf0332 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java
index 95d4354..7e732dc 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
import java.util.Iterator;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
import org.testng.Assert;
import org.testng.annotations.Test;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java
index 3f33f46..03d2b3a 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
import java.util.Iterator;
import java.util.List;
@@ -25,9 +25,9 @@ import org.testng.annotations.Test;
import com.google.common.collect.Lists;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+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/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java
index 8dc0c94..7db8373 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
import java.util.Iterator;
@@ -23,8 +23,8 @@ import org.apache.hadoop.io.Text;
import org.testng.Assert;
import org.testng.annotations.Test;
-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/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java b/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java
index d97fe46..3170633 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.fork;
+package org.apache.gobblin.fork;
import java.util.Arrays;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java b/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java
index eaaa264..700e7b2 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.fork;
+package org.apache.gobblin.fork;
import org.apache.avro.Schema;
import org.testng.Assert;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java
index a3c5b8b..c9f042a 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package gobblin.fork;
+package org.apache.gobblin.fork;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
import java.util.Arrays;
import java.util.List;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java b/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java
index 7c97d2e..e82252d 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.http;
+package org.apache.gobblin.http;
import org.apache.http.HttpHost;
import org.testng.Assert;
@@ -25,8 +25,8 @@ import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
import com.typesafe.config.ConfigValueFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
/**
* Unit tests for {@link DefaultHttpClientConfigurator}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java b/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java
index 499e570..db50179 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.http;
+package org.apache.gobblin.http;
import org.testng.Assert;
import org.testng.Assert.ThrowingRunnable;
@@ -24,7 +24,7 @@ import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
import com.typesafe.config.ConfigValueFactory;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
/**
* Unit tests for {@link HttpClientConfiguratorLoader}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java b/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java
index c738204..6cea0de 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.instrumented;
+package org.apache.gobblin.instrumented;
import java.util.HashMap;
import java.util.Map;
@@ -23,12 +23,12 @@ import java.util.Map;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.Constructs;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.configuration.State;
-import gobblin.metrics.MetricContext;
-import gobblin.instrumented.extractor.InstrumentedExtractor;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.instrumented.extractor.InstrumentedExtractor;
@Test(groups = { "gobblin.core" })
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java b/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java
index be40401..f3b1de1 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.policies.count;
+package org.apache.gobblin.policies.count;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
-import gobblin.qualitychecker.task.TaskLevelPolicy.Result;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy.Result;
import org.testng.Assert;
import org.testng.annotations.Test;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java b/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java
index 3522c29..ef68fd1 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.File;
import java.io.FileInputStream;
@@ -38,15 +38,15 @@ import org.testng.annotations.Test;
import com.google.common.collect.ImmutableList;
import com.google.common.io.Files;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metadata.MetadataMerger;
-import gobblin.metadata.types.GlobalMetadata;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.writer.FsDataWriter;
-import gobblin.writer.FsWriterMetrics;
-import gobblin.writer.PartitionIdentifier;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metadata.MetadataMerger;
+import org.apache.gobblin.metadata.types.GlobalMetadata;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.writer.FsDataWriter;
+import org.apache.gobblin.writer.FsWriterMetrics;
+import org.apache.gobblin.writer.PartitionIdentifier;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
index 690a1aa..e8edba6 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
@@ -15,19 +15,19 @@
* limitations under the License.
*/
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
-import gobblin.qualitychecker.task.TaskLevelPolicyChecker;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory;
import java.util.Map;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
@Test(groups = {"gobblin.qualitychecker"})
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
index 26add73..1ce5868 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicyCheckResults;
-import gobblin.qualitychecker.row.RowLevelPolicyChecker;
-import gobblin.qualitychecker.row.RowLevelPolicyCheckerBuilderFactory;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckerBuilderFactory;
import java.io.File;
import java.net.URI;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
index 35d1f6c..8bd8edf 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
@@ -15,19 +15,19 @@
* limitations under the License.
*/
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
-import gobblin.qualitychecker.task.TaskLevelPolicyChecker;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory;
import java.util.Map;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
@Test(groups = {"gobblin.qualitychecker"})
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java
index 105047d..e0ece28 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
public class TestConstants {
public static final String TEST_FS_URI = "file://localhost/";
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java
index 97a849f..7c4c33d 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
public class TestRowLevelPolicy extends RowLevelPolicy {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java
index e5cbcb5..fb2458a 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
public class TestRowLevelPolicyFail extends RowLevelPolicy {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java
index 883440e..e995dd3 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
public class TestTaskLevelPolicy extends TaskLevelPolicy {