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;
