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 {
