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:48 UTC
[30/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/fork/IdentityForkOperator.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/fork/IdentityForkOperator.java b/gobblin-core/src/main/java/org/apache/gobblin/fork/IdentityForkOperator.java
index 890a3f6..77bf98a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/fork/IdentityForkOperator.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/fork/IdentityForkOperator.java
@@ -15,15 +15,15 @@
* limitations under the License.
*/
-package gobblin.fork;
+package org.apache.gobblin.fork;
import java.io.IOException;
import java.util.List;
import com.google.common.collect.Lists;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/http/DefaultHttpClientConfigurator.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/http/DefaultHttpClientConfigurator.java b/gobblin-core/src/main/java/org/apache/gobblin/http/DefaultHttpClientConfigurator.java
index f09cec7..b8926fa 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/http/DefaultHttpClientConfigurator.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/http/DefaultHttpClientConfigurator.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 java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -31,8 +31,8 @@ import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
import com.typesafe.config.ConfigValueFactory;
-import gobblin.annotation.Alias;
-import gobblin.configuration.State;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.configuration.State;
/**
* Default implementation that uses the following properties to configure an {@link HttpClient}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfigurator.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfigurator.java b/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfigurator.java
index eab17dc..6c773f6 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfigurator.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfigurator.java
@@ -14,14 +14,14 @@
* 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.client.HttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import com.typesafe.config.Config;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
/**
* An adapter from Gobblin configuration to {@link HttpClientBuilder}. It can also be used to
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfiguratorLoader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfiguratorLoader.java b/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfiguratorLoader.java
index 6fdfffa..a1762ad 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfiguratorLoader.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/http/HttpClientConfiguratorLoader.java
@@ -14,15 +14,15 @@
* 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.client.HttpClient;
import com.google.common.base.Optional;
import com.typesafe.config.Config;
-import gobblin.configuration.State;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.ClassAliasResolver;
/**
* Creates an instance of HttpClientConfigurator using dependency injection from configuration.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/initializer/MultiInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/initializer/MultiInitializer.java b/gobblin-core/src/main/java/org/apache/gobblin/initializer/MultiInitializer.java
index 408cba8..44fa8b4 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/initializer/MultiInitializer.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/initializer/MultiInitializer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.initializer;
+package org.apache.gobblin.initializer;
import java.io.IOException;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/net/Request.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/net/Request.java b/gobblin-core/src/main/java/org/apache/gobblin/net/Request.java
index 367e1bf..c06f384 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/net/Request.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/net/Request.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.net;
+package org.apache.gobblin.net;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderGuidPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderGuidPolicy.java b/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderGuidPolicy.java
index ae436dc..83ac25b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderGuidPolicy.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderGuidPolicy.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.policies.avro;
+package org.apache.gobblin.policies.avro;
import org.apache.avro.generic.GenericRecord;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
/**
* A policy that checks whether an Avro record has header.guid field.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderTimestampPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderTimestampPolicy.java b/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderTimestampPolicy.java
index b28cd52..36334b4 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderTimestampPolicy.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroHeaderTimestampPolicy.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.policies.avro;
+package org.apache.gobblin.policies.avro;
import org.apache.avro.generic.GenericRecord;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroRecordTimestampLowerBoundPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroRecordTimestampLowerBoundPolicy.java b/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroRecordTimestampLowerBoundPolicy.java
index b0da9f4..20fa63c 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroRecordTimestampLowerBoundPolicy.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/policies/avro/AvroRecordTimestampLowerBoundPolicy.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.policies.avro;
+package org.apache.gobblin.policies.avro;
-import gobblin.configuration.State;
-import gobblin.policies.time.RecordTimestampLowerBoundPolicy;
-import gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
-import gobblin.writer.partitioner.TimeBasedWriterPartitioner;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.policies.time.RecordTimestampLowerBoundPolicy;
+import org.apache.gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
+import org.apache.gobblin.writer.partitioner.TimeBasedWriterPartitioner;
/**
* An implementation of {@link RecordTimestampLowerBoundPolicy} for Avro records.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountPolicy.java b/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountPolicy.java
index 1a84d7e..4a587b5 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountPolicy.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountPolicy.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.policies.count;
+package org.apache.gobblin.policies.count;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
public class RowCountPolicy extends TaskLevelPolicy {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountRangePolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountRangePolicy.java b/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountRangePolicy.java
index 7aa93c3..7f2efcf 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountRangePolicy.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/policies/count/RowCountRangePolicy.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.policies.count;
+package org.apache.gobblin.policies.count;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
public class RowCountRangePolicy extends TaskLevelPolicy {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaCompatibilityPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaCompatibilityPolicy.java b/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaCompatibilityPolicy.java
index 82d9281..5373479 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaCompatibilityPolicy.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaCompatibilityPolicy.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.policies.schema;
+package org.apache.gobblin.policies.schema;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
public class SchemaCompatibilityPolicy extends TaskLevelPolicy {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaRowCheckPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaRowCheckPolicy.java b/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaRowCheckPolicy.java
index b1fbb7b..f9ff603 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaRowCheckPolicy.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/policies/schema/SchemaRowCheckPolicy.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.policies.schema;
+package org.apache.gobblin.policies.schema;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
public class SchemaRowCheckPolicy extends RowLevelPolicy {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/policies/time/RecordTimestampLowerBoundPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/policies/time/RecordTimestampLowerBoundPolicy.java b/gobblin-core/src/main/java/org/apache/gobblin/policies/time/RecordTimestampLowerBoundPolicy.java
index 0cb7352..18997e2 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/policies/time/RecordTimestampLowerBoundPolicy.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/policies/time/RecordTimestampLowerBoundPolicy.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.policies.time;
+package org.apache.gobblin.policies.time;
import org.joda.time.DateTime;
import org.joda.time.DateTimeZone;
@@ -25,10 +25,10 @@ import org.joda.time.format.PeriodFormatterBuilder;
import com.google.common.base.Optional;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicy;
-import gobblin.writer.partitioner.TimeBasedWriterPartitioner;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.writer.partitioner.TimeBasedWriterPartitioner;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java
index c5cd2e4..0a3408e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.IOException;
import java.net.URI;
@@ -47,19 +47,19 @@ import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
import com.google.common.io.Closer;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metadata.MetadataMerger;
-import gobblin.metadata.types.StaticStringMetadataMerger;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.util.HadoopUtils;
-import gobblin.util.ParallelRunner;
-import gobblin.util.WriterUtils;
-import gobblin.util.reflection.GobblinConstructorUtils;
-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.StaticStringMetadataMerger;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.ParallelRunner;
+import org.apache.gobblin.util.WriterUtils;
+import org.apache.gobblin.util.reflection.GobblinConstructorUtils;
+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/main/java/org/apache/gobblin/publisher/BaseDataPublisherWithHiveRegistration.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisherWithHiveRegistration.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisherWithHiveRegistration.java
index 8c8e3ac..f9f7d28 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisherWithHiveRegistration.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisherWithHiveRegistration.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.IOException;
import java.util.Collection;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/CommitSequencePublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/CommitSequencePublisher.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/CommitSequencePublisher.java
index 9ca3d99..f74e76f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/CommitSequencePublisher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/CommitSequencePublisher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.IOException;
import java.util.Collection;
@@ -25,13 +25,13 @@ import org.apache.hadoop.fs.Path;
import com.google.common.base.Optional;
import com.google.common.collect.Iterables;
-import gobblin.annotation.Alpha;
-import gobblin.commit.CommitSequence;
-import gobblin.commit.FsRenameCommitStep;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.util.ParallelRunner;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.commit.CommitSequence;
+import org.apache.gobblin.commit.FsRenameCommitStep;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.util.ParallelRunner;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/HiveRegistrationPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/HiveRegistrationPublisher.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/HiveRegistrationPublisher.java
index ba490ab..281acbe 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/HiveRegistrationPublisher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/HiveRegistrationPublisher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.IOException;
import java.util.Collection;
@@ -36,18 +36,18 @@ import com.google.common.base.Splitter;
import com.google.common.collect.Sets;
import com.google.common.io.Closer;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.hive.HiveRegProps;
-import gobblin.hive.HiveRegister;
-import gobblin.hive.policy.HiveRegistrationPolicy;
-import gobblin.hive.policy.HiveRegistrationPolicyBase;
-import gobblin.hive.metastore.HiveMetaStoreUtils;
-import gobblin.hive.spec.HiveSpec;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.hive.HiveRegProps;
+import org.apache.gobblin.hive.HiveRegister;
+import org.apache.gobblin.hive.policy.HiveRegistrationPolicy;
+import org.apache.gobblin.hive.policy.HiveRegistrationPolicyBase;
+import org.apache.gobblin.hive.metastore.HiveMetaStoreUtils;
+import org.apache.gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.util.ExecutorsUtils;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/NoopPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/NoopPublisher.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/NoopPublisher.java
index 2defb61..c256bc1 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/NoopPublisher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/NoopPublisher.java
@@ -15,15 +15,15 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.IOException;
import java.util.Collection;
import lombok.extern.slf4j.Slf4j;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisher.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisher.java
index f8bbae7..5ca87b0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisher.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.WorkUnitState;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
public class TaskPublisher {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilder.java
index 5f073e4..42fef75 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilder.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
-import gobblin.configuration.WorkUnitState;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
public class TaskPublisherBuilder {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilderFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilderFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilderFactory.java
index 8506d44..15cdfaa 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilderFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TaskPublisherBuilderFactory.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
-import gobblin.configuration.WorkUnitState;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
public class TaskPublisherBuilderFactory {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedDataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedDataPublisher.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedDataPublisher.java
index 567de04..dbe7539 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedDataPublisher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedDataPublisher.java
@@ -15,18 +15,18 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.IOException;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.Path;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.util.FileListUtils;
-import gobblin.util.ParallelRunner;
-import gobblin.util.WriterUtils;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.util.FileListUtils;
+import org.apache.gobblin.util.ParallelRunner;
+import org.apache.gobblin.util.WriterUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisher.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisher.java
index 4eaa557..89ecdf6 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisher.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.IOException;
import java.util.Set;
import org.apache.hadoop.fs.Path;
import com.google.common.base.Preconditions;
-import gobblin.util.ParallelRunner;
-import gobblin.util.WriterUtils;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.util.ParallelRunner;
+import org.apache.gobblin.util.WriterUtils;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisherWithHiveRegistration.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisherWithHiveRegistration.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisherWithHiveRegistration.java
index 7fb1752..4fec845 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisherWithHiveRegistration.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisherWithHiveRegistration.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
import java.io.IOException;
import java.util.Collection;
import org.apache.hadoop.fs.Path;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelErrFileWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelErrFileWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelErrFileWriter.java
index 561be6f..1d5fd9c 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelErrFileWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelErrFileWriter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.row;
+package org.apache.gobblin.qualitychecker.row;
import java.io.BufferedWriter;
import java.io.Closeable;
@@ -28,7 +28,7 @@ import org.apache.hadoop.fs.Path;
import com.google.common.io.Closer;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckResults.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckResults.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckResults.java
index 425eef9..83c93f9 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckResults.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckResults.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.row;
+package org.apache.gobblin.qualitychecker.row;
import java.util.ArrayList;
import java.util.HashMap;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java
index 12cc604..5c92347 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.row;
+package org.apache.gobblin.qualitychecker.row;
import java.io.Closeable;
import java.io.IOException;
@@ -28,17 +28,17 @@ import org.apache.hadoop.fs.Path;
import com.google.common.base.Strings;
import com.google.common.io.Closer;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.stream.ControlMessage;
-import gobblin.records.ControlMessageHandler;
-import gobblin.records.RecordStreamProcessor;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.stream.RecordEnvelope;
-import gobblin.stream.StreamEntity;
-import gobblin.util.FinalState;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.records.RecordStreamProcessor;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.stream.StreamEntity;
+import org.apache.gobblin.util.FinalState;
+import org.apache.gobblin.util.HadoopUtils;
import io.reactivex.Flowable;
import javax.annotation.concurrent.ThreadSafe;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilder.java
index 8d01126..47f54101 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilder.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.row;
+package org.apache.gobblin.qualitychecker.row;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
import java.lang.reflect.Constructor;
import java.util.ArrayList;
import java.util.List;
@@ -28,9 +28,9 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Splitter;
import com.google.common.collect.Lists;
-import gobblin.configuration.State;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.util.WriterUtils;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.util.WriterUtils;
public class RowLevelPolicyCheckerBuilder {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilderFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilderFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilderFactory.java
index b3d51b5..7f2998e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilderFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyCheckerBuilderFactory.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.row;
+package org.apache.gobblin.qualitychecker.row;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
public class RowLevelPolicyCheckerBuilderFactory {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckResults.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckResults.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckResults.java
index 54cec19..6233f38 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckResults.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckResults.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.task;
+package org.apache.gobblin.qualitychecker.task;
import java.util.HashMap;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyChecker.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyChecker.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyChecker.java
index b08e3ca..0a0001c 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyChecker.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyChecker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.task;
+package org.apache.gobblin.qualitychecker.task;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilder.java
index 45e5939..2e7c175 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilder.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.task;
+package org.apache.gobblin.qualitychecker.task;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
import java.lang.reflect.Constructor;
import java.util.ArrayList;
import java.util.List;
@@ -28,8 +28,8 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Splitter;
import com.google.common.collect.Lists;
-import gobblin.configuration.State;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.ForkOperatorUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilderFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilderFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilderFactory.java
index 9867ee1..4b47eae 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilderFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyCheckerBuilderFactory.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.qualitychecker.task;
+package org.apache.gobblin.qualitychecker.task;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
public class TaskLevelPolicyCheckerBuilderFactory {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessor.java b/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessor.java
index e82bce9..d51b5db 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessor.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
import java.util.HashMap;
import java.util.Iterator;
@@ -30,7 +30,7 @@ import org.apache.avro.util.Utf8;
import com.google.common.base.Optional;
import com.google.common.base.Splitter;
-import gobblin.util.AvroUtils;
+import org.apache.gobblin.util.AvroUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/CoreRecordAccessProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/CoreRecordAccessProvider.java b/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/CoreRecordAccessProvider.java
index e89c8c5..5eb9e71 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/CoreRecordAccessProvider.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/CoreRecordAccessProvider.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
import org.apache.avro.generic.GenericRecord;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactory.java
index cc5c137..4d28522 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactory.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
import java.util.ServiceLoader;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/retry/RetryerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/retry/RetryerFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/retry/RetryerFactory.java
index d674397..0c41d66 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/retry/RetryerFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/retry/RetryerFactory.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.retry;
+package org.apache.gobblin.retry;
import java.util.Map;
import java.util.concurrent.TimeUnit;
@@ -31,7 +31,7 @@ import com.google.common.collect.ImmutableMap;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.writer.exception.NonTransientException;
+import org.apache.gobblin.writer.exception.NonTransientException;
/**
* Factory class that builds Retryer.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/security/ssl/SSLContextFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/security/ssl/SSLContextFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/security/ssl/SSLContextFactory.java
index 5bb27c0..e6dec3f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/security/ssl/SSLContextFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/security/ssl/SSLContextFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.security.ssl;
+package org.apache.gobblin.security.ssl;
import java.io.ByteArrayInputStream;
import java.io.File;
@@ -31,8 +31,8 @@ import javax.net.ssl.KeyManagerFactory;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManagerFactory;
-import gobblin.password.PasswordManager;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.util.ConfigUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java
index 6a81102..c3e9d08 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java
@@ -15,18 +15,18 @@
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
import java.io.IOException;
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericRecord;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DatePartitionedAvroFileExtractor;
-import gobblin.source.extractor.Extractor;
-import gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DatePartitionedAvroFileExtractor;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java
index 259b465..85ceb88 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java
@@ -10,11 +10,11 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.util.DatePartitionType;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.util.DatePartitionType;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java
index c0bc1dc..a9ff257 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
import java.io.IOException;
import java.util.ArrayList;
@@ -38,14 +38,14 @@ import com.google.common.base.Enums;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.source.extractor.hadoop.HadoopFsHelper;
-import gobblin.util.DatePartitionType;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.hadoop.HadoopFsHelper;
+import org.apache.gobblin.util.DatePartitionType;
-import static gobblin.source.PartitionedFileSourceBase.DATE_PARTITIONED_SOURCE_PARTITION_PATTERN;
+import static org.apache.gobblin.source.PartitionedFileSourceBase.DATE_PARTITIONED_SOURCE_PARTITION_PATTERN;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetriever.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetriever.java b/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetriever.java
index 4510ac9..c1df008 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetriever.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetriever.java
@@ -14,12 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
import java.io.IOException;
import java.util.List;
-import gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.SourceState;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetrieverUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetrieverUtils.java b/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetrieverUtils.java
index 926267d..4bab517 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetrieverUtils.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetrieverUtils.java
@@ -14,17 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
import org.joda.time.Duration;
-import gobblin.configuration.State;
-import gobblin.util.DatePartitionType;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.DatePartitionType;
-import static gobblin.source.PartitionedFileSourceBase.DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME;
-import static gobblin.source.PartitionedFileSourceBase.DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME_GRANULARITY;
-import static gobblin.source.PartitionedFileSourceBase.DEFAULT_DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME_GRANULARITY;
-import static gobblin.source.PartitionedFileSourceBase.DEFAULT_PARTITIONED_SOURCE_PARTITION_LEAD_TIME;
+import static org.apache.gobblin.source.PartitionedFileSourceBase.DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME;
+import static org.apache.gobblin.source.PartitionedFileSourceBase.DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME_GRANULARITY;
+import static org.apache.gobblin.source.PartitionedFileSourceBase.DEFAULT_DATE_PARTITIONED_SOURCE_PARTITION_LEAD_TIME_GRANULARITY;
+import static org.apache.gobblin.source.PartitionedFileSourceBase.DEFAULT_PARTITIONED_SOURCE_PARTITION_LEAD_TIME;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionedFileSourceBase.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionedFileSourceBase.java b/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionedFileSourceBase.java
index de26450..d317e54 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionedFileSourceBase.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/PartitionedFileSourceBase.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
import java.io.IOException;
import java.util.Collections;
@@ -33,20 +33,20 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Throwables;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.source.extractor.filebased.FileBasedSource;
-import gobblin.source.extractor.hadoop.AvroFsHelper;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.Extract.TableType;
-import gobblin.source.workunit.MultiWorkUnitWeightedQueue;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.DatePartitionType;
-import gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.filebased.FileBasedSource;
+import org.apache.gobblin.source.extractor.hadoop.AvroFsHelper;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.Extract.TableType;
+import org.apache.gobblin.source.workunit.MultiWorkUnitWeightedQueue;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.DatePartitionType;
+import org.apache.gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/RegexBasedPartitionedRetriever.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/RegexBasedPartitionedRetriever.java b/gobblin-core/src/main/java/org/apache/gobblin/source/RegexBasedPartitionedRetriever.java
index 8ad8341..e082bda 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/RegexBasedPartitionedRetriever.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/RegexBasedPartitionedRetriever.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
import java.io.IOException;
import java.util.ArrayList;
@@ -34,10 +34,10 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Preconditions;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.source.extractor.hadoop.HadoopFsHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.hadoop.HadoopFsHelper;
public class RegexBasedPartitionedRetriever implements PartitionAwareFileRetriever {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/RegexPartitionedAvroFileSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/RegexPartitionedAvroFileSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/RegexPartitionedAvroFileSource.java
index eeba091..2f93e85 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/RegexPartitionedAvroFileSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/RegexPartitionedAvroFileSource.java
@@ -14,16 +14,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
import java.io.IOException;
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericRecord;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.hadoop.AvroFileExtractor;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.hadoop.AvroFileExtractor;
public class RegexPartitionedAvroFileSource extends PartitionedFileSourceBase<Schema, GenericRecord> {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java
index ffba255..51af03a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.hadoop.AvroFileExtractor;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.hadoop.AvroFileExtractor;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DummyExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DummyExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DummyExtractor.java
index 1a4824c..dbbb1b7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DummyExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DummyExtractor.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
import java.io.IOException;
-import gobblin.configuration.WorkUnitState;
-import gobblin.instrumented.extractor.InstrumentedExtractor;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.instrumented.extractor.InstrumentedExtractor;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/ExtractPrepareException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/ExtractPrepareException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/ExtractPrepareException.java
index a5704ba..5c7c9ca 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/ExtractPrepareException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/ExtractPrepareException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.exception;
+package org.apache.gobblin.source.extractor.exception;
public class ExtractPrepareException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/HighWatermarkException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/HighWatermarkException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/HighWatermarkException.java
index 9c8b291..4f7ad38 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/HighWatermarkException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/HighWatermarkException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.exception;
+package org.apache.gobblin.source.extractor.exception;
public class HighWatermarkException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/MetadataException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/MetadataException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/MetadataException.java
index b37a749..1ebdf9e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/MetadataException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/MetadataException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.exception;
+package org.apache.gobblin.source.extractor.exception;
public class MetadataException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RecordCountException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RecordCountException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RecordCountException.java
index 20adec46..370aef3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RecordCountException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RecordCountException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.exception;
+package org.apache.gobblin.source.extractor.exception;
public class RecordCountException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiClientException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiClientException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiClientException.java
index 62d72ad..23f4c3a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiClientException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiClientException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.exception;
+package org.apache.gobblin.source.extractor.exception;
public class RestApiClientException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiConnectionException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiConnectionException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiConnectionException.java
index 348591d..684d3f8 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiConnectionException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiConnectionException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.exception;
+package org.apache.gobblin.source.extractor.exception;
public class RestApiConnectionException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiProcessingException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiProcessingException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiProcessingException.java
index f164bc0..71b7ff3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiProcessingException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/RestApiProcessingException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.exception;
+package org.apache.gobblin.source.extractor.exception;
public class RestApiProcessingException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/SchemaException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/SchemaException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/SchemaException.java
index 5a6ff38..cafacb6 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/SchemaException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/SchemaException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.exception;
+package org.apache.gobblin.source.extractor.exception;
public class SchemaException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/Command.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/Command.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/Command.java
index 1d3c6e3..92e7433 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/Command.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/Command.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
import java.util.Collection;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandOutput.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandOutput.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandOutput.java
index 330f800..0e9d174 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandOutput.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandOutput.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandType.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandType.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandType.java
index 8254af8..6b668f1 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandType.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/CommandType.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
/**
* Interface for all source to
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ExtractType.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ExtractType.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ExtractType.java
index 022a89a..a8ae7bf 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ExtractType.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ExtractType.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
public enum ExtractType {
SNAPSHOT, APPEND_DAILY, APPEND_HOURLY, APPEND_BATCH
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ProtocolSpecificLayer.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ProtocolSpecificLayer.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ProtocolSpecificLayer.java
index 98e7eae..748adfe 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ProtocolSpecificLayer.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/ProtocolSpecificLayer.java
@@ -15,20 +15,20 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.watermark.WatermarkType;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.watermark.WatermarkType;
import java.io.IOException;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
-import gobblin.source.extractor.watermark.Predicate;
-import gobblin.source.extractor.exception.HighWatermarkException;
-import gobblin.source.extractor.exception.RecordCountException;
-import gobblin.source.extractor.exception.SchemaException;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.extractor.watermark.Predicate;
+import org.apache.gobblin.source.extractor.exception.HighWatermarkException;
+import org.apache.gobblin.source.extractor.exception.RecordCountException;
+import org.apache.gobblin.source.extractor.exception.SchemaException;
+import org.apache.gobblin.source.workunit.WorkUnit;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractor.java
index 2826797..5345e35 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
import java.io.IOException;
import java.util.ArrayList;
@@ -33,24 +33,24 @@ import com.google.gson.JsonObject;
import lombok.extern.slf4j.Slf4j;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.exception.ExtractPrepareException;
-import gobblin.source.extractor.exception.HighWatermarkException;
-import gobblin.source.extractor.exception.RecordCountException;
-import gobblin.source.extractor.exception.SchemaException;
-import gobblin.source.extractor.partition.Partition;
-import gobblin.source.extractor.schema.ArrayDataType;
-import gobblin.source.extractor.schema.DataType;
-import gobblin.source.extractor.schema.EnumDataType;
-import gobblin.source.extractor.schema.MapDataType;
-import gobblin.source.extractor.utils.Utils;
-import gobblin.source.extractor.watermark.Predicate;
-import gobblin.source.extractor.watermark.WatermarkPredicate;
-import gobblin.source.extractor.watermark.WatermarkType;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.exception.ExtractPrepareException;
+import org.apache.gobblin.source.extractor.exception.HighWatermarkException;
+import org.apache.gobblin.source.extractor.exception.RecordCountException;
+import org.apache.gobblin.source.extractor.exception.SchemaException;
+import org.apache.gobblin.source.extractor.partition.Partition;
+import org.apache.gobblin.source.extractor.schema.ArrayDataType;
+import org.apache.gobblin.source.extractor.schema.DataType;
+import org.apache.gobblin.source.extractor.schema.EnumDataType;
+import org.apache.gobblin.source.extractor.schema.MapDataType;
+import org.apache.gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.watermark.Predicate;
+import org.apache.gobblin.source.extractor.watermark.WatermarkPredicate;
+import org.apache.gobblin.source.extractor.watermark.WatermarkType;
+import org.apache.gobblin.source.workunit.WorkUnit;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java
index c41e847..5e016da 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
import java.util.Collection;
import java.util.Collections;
@@ -36,29 +36,29 @@ import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
-import gobblin.config.client.ConfigClient;
-import gobblin.config.client.ConfigClientCache;
-import gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException;
-import gobblin.config.client.api.VersionStabilityPolicy;
-import gobblin.config.store.api.ConfigStoreCreationException;
-import gobblin.config.store.api.VersionDoesNotExistException;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.configuration.WorkUnitState.WorkingState;
-import gobblin.source.extractor.JobCommitPolicy;
-import gobblin.source.extractor.partition.Partition;
-import gobblin.source.extractor.partition.Partitioner;
-import gobblin.source.extractor.utils.Utils;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.Extract.TableType;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.ConfigUtils;
-import gobblin.util.DatasetFilterUtils;
-import gobblin.util.PathUtils;
-import gobblin.util.dataset.DatasetUtils;
+import org.apache.gobblin.config.client.ConfigClient;
+import org.apache.gobblin.config.client.ConfigClientCache;
+import org.apache.gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException;
+import org.apache.gobblin.config.client.api.VersionStabilityPolicy;
+import org.apache.gobblin.config.store.api.ConfigStoreCreationException;
+import org.apache.gobblin.config.store.api.VersionDoesNotExistException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState.WorkingState;
+import org.apache.gobblin.source.extractor.JobCommitPolicy;
+import org.apache.gobblin.source.extractor.partition.Partition;
+import org.apache.gobblin.source.extractor.partition.Partitioner;
+import org.apache.gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.Extract.TableType;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.DatasetFilterUtils;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.dataset.DatasetUtils;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/SourceSpecificLayer.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/SourceSpecificLayer.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/SourceSpecificLayer.java
index 97ee445..18c8a3e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/SourceSpecificLayer.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/SourceSpecificLayer.java
@@ -15,19 +15,19 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.exception.HighWatermarkException;
-import gobblin.source.extractor.watermark.Predicate;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.exception.HighWatermarkException;
+import org.apache.gobblin.source.extractor.watermark.Predicate;
import java.io.IOException;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
-import gobblin.source.extractor.exception.RecordCountException;
-import gobblin.source.extractor.exception.SchemaException;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.extractor.exception.RecordCountException;
+import org.apache.gobblin.source.extractor.exception.SchemaException;
+import org.apache.gobblin.source.workunit.WorkUnit;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommand.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommand.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommand.java
index 514f51d..4357262 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommand.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommand.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract.restapi;
+package org.apache.gobblin.source.extractor.extract.restapi;
-import gobblin.source.extractor.extract.Command;
-import gobblin.source.extractor.extract.CommandType;
+import org.apache.gobblin.source.extractor.extract.Command;
+import org.apache.gobblin.source.extractor.extract.CommandType;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommandOutput.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommandOutput.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommandOutput.java
index fb573ac..21bf70a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommandOutput.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiCommandOutput.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract.restapi;
+package org.apache.gobblin.source.extractor.extract.restapi;
import java.util.HashMap;
import java.util.Map;
-import gobblin.source.extractor.extract.CommandOutput;
+import org.apache.gobblin.source.extractor.extract.CommandOutput;
public class RestApiCommandOutput implements CommandOutput<RestApiCommand, String> {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiConnector.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiConnector.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiConnector.java
index 251a768..ae1f3aa 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiConnector.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiConnector.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor.extract.restapi;
+package org.apache.gobblin.source.extractor.extract.restapi;
import java.io.IOException;
import java.util.Arrays;
@@ -36,14 +36,14 @@ import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.http.HttpClientConfiguratorLoader;
-import gobblin.source.extractor.exception.RestApiConnectionException;
-import gobblin.source.extractor.exception.RestApiProcessingException;
-import gobblin.source.extractor.extract.Command;
-import gobblin.source.extractor.extract.CommandOutput;
-import gobblin.source.extractor.extract.restapi.RestApiCommand.RestApiCommandType;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.http.HttpClientConfiguratorLoader;
+import org.apache.gobblin.source.extractor.exception.RestApiConnectionException;
+import org.apache.gobblin.source.extractor.exception.RestApiProcessingException;
+import org.apache.gobblin.source.extractor.extract.Command;
+import org.apache.gobblin.source.extractor.extract.CommandOutput;
+import org.apache.gobblin.source.extractor.extract.restapi.RestApiCommand.RestApiCommandType;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;