http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java index e1471ac..5d5025e 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.scheduler; +package org.apache.gobblin.scheduler; import java.io.File; import java.io.FileReader; @@ -42,8 +42,8 @@ import com.google.common.collect.Lists; import com.google.common.collect.Sets; import com.google.common.util.concurrent.ServiceManager; -import gobblin.configuration.ConfigurationKeys; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.testing.AssertWithBackoff; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java index dbf5259..b02832b 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.filebased; +package org.apache.gobblin.source.extractor.filebased; import java.io.File; import java.util.Set; @@ -29,11 +29,11 @@ import com.google.common.base.Charsets; import com.google.common.collect.Sets; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.embedded.EmbeddedGobblin; -import gobblin.writer.test.GobblinTestEventBusWriter; -import gobblin.writer.test.TestingEventBusAsserter; -import gobblin.writer.test.TestingEventBuses; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.embedded.EmbeddedGobblin; +import org.apache.gobblin.writer.test.GobblinTestEventBusWriter; +import org.apache.gobblin.writer.test.TestingEventBusAsserter; +import org.apache.gobblin.writer.test.TestingEventBuses; public class TextFileBasedSourceTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java index dfac6c7..c42e605 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.spec_catalog; +package org.apache.gobblin.spec_catalog; import java.io.File; import java.net.URI; @@ -37,14 +37,14 @@ import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.typesafe.config.Config; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.runtime.spec_catalog.FlowCatalog; -import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; -import gobblin.util.ConfigUtils; -import gobblin.util.PathUtils; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.runtime.spec_catalog.FlowCatalog; +import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PathUtils; public class FlowCatalogTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java index dd98e85..594c755 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.spec_catalog; +package org.apache.gobblin.spec_catalog; import java.io.File; import java.net.URI; @@ -36,14 +36,14 @@ import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.typesafe.config.Config; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.runtime.spec_catalog.TopologyCatalog; -import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; -import gobblin.util.ConfigUtils; -import gobblin.util.PathUtils; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog; +import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PathUtils; public class TopologyCatalogTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java index dc24bc4..7056b12 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.task; +package org.apache.gobblin.task; import com.google.common.collect.HashMultimap; import com.google.common.collect.SetMultimap; import com.google.common.collect.Sets; import com.google.common.eventbus.EventBus; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobExecutionResult; -import gobblin.runtime.embedded.EmbeddedGobblin; -import gobblin.writer.test.TestingEventBuses; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobExecutionResult; +import org.apache.gobblin.runtime.embedded.EmbeddedGobblin; +import org.apache.gobblin.writer.test.TestingEventBuses; import java.io.File; import java.util.Set; import java.util.UUID; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java b/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java index bc47446..f4168df 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.task; +package org.apache.gobblin.task; import java.io.IOException; import java.util.Collection; @@ -32,21 +32,21 @@ import com.google.common.collect.SetMultimap; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.publisher.DataPublisher; -import gobblin.publisher.NoopPublisher; -import gobblin.runtime.JobState; -import gobblin.runtime.TaskContext; -import gobblin.runtime.TaskState; -import gobblin.runtime.task.BaseAbstractTask; -import gobblin.runtime.task.TaskFactory; -import gobblin.runtime.task.TaskIFace; -import gobblin.runtime.task.TaskUtils; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.WorkUnit; -import gobblin.writer.test.TestingEventBuses; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.publisher.DataPublisher; +import org.apache.gobblin.publisher.NoopPublisher; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.runtime.TaskContext; +import org.apache.gobblin.runtime.TaskState; +import org.apache.gobblin.runtime.task.BaseAbstractTask; +import org.apache.gobblin.runtime.task.TaskFactory; +import org.apache.gobblin.runtime.task.TaskIFace; +import org.apache.gobblin.runtime.task.TaskUtils; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.writer.test.TestingEventBuses; import lombok.Data; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java index 4dbe12f..f42f9c1 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.lang.reflect.Type; import java.util.Map; @@ -28,9 +28,9 @@ import com.google.gson.Gson; import com.google.gson.JsonElement; import com.google.gson.reflect.TypeToken; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.SingleRecordIterable; -import gobblin.converter.ToAvroConverterBase; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.converter.ToAvroConverterBase; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java index 4b2fad0..b28117b 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.lang.reflect.Type; import java.util.Map; @@ -28,13 +28,13 @@ import com.google.gson.Gson; import com.google.gson.JsonElement; import com.google.gson.reflect.TypeToken; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.fork.CopyNotSupportedException; -import gobblin.fork.CopyableGenericRecord; -import gobblin.fork.CopyableSchema; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.fork.CopyNotSupportedException; +import org.apache.gobblin.fork.CopyableGenericRecord; +import org.apache.gobblin.fork.CopyableSchema; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java index 59d33f8..8af01a7 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.io.IOException; import java.util.Collection; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.publisher.DataPublisher; -import gobblin.publisher.SingleTaskDataPublisher; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.publisher.DataPublisher; +import org.apache.gobblin.publisher.SingleTaskDataPublisher; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java index cb4fb43..8843d67 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.io.IOException; import java.net.URI; @@ -32,9 +32,9 @@ import org.apache.hadoop.fs.Path; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.Extractor; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.Extractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java index 2c36f49..aa1b548 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java @@ -15,23 +15,23 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.util.List; import com.google.common.base.Splitter; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.Source; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.extract.AbstractSource; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.Extract.TableType; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.extract.AbstractSource; +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; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java index b30d898..43696f8 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import com.google.common.collect.Sets; import com.google.common.io.Files; -import gobblin.util.filesystem.PathAlterationListener; -import gobblin.util.filesystem.PathAlterationListenerAdaptor; -import gobblin.util.filesystem.PathAlterationObserverScheduler; +import org.apache.gobblin.util.filesystem.PathAlterationListener; +import org.apache.gobblin.util.filesystem.PathAlterationListenerAdaptor; +import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler; import java.io.File; import java.io.FileWriter; import java.io.IOException; @@ -38,7 +38,7 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java index 9087496..a4ab15d 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.File; import java.io.FileWriter; @@ -35,10 +35,10 @@ import org.testng.annotations.Test; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator; -import gobblin.runtime.template.HOCONInputStreamJobTemplate; -import gobblin.runtime.template.ResourceBasedJobTemplate; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator; +import org.apache.gobblin.runtime.template.HOCONInputStreamJobTemplate; +import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java index ad452d1..e868cd6 100644 --- a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java +++ b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.salesforce; +package org.apache.gobblin.salesforce; public class SalesforceConfigurationKeys { public static final String SOURCE_QUERYBASED_SALESFORCE_IS_SOFT_DELETES_PULL_DISABLED = http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java ---------------------------------------------------------------------- diff --git a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java index f9cec5b..f95e7f7 100644 --- a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java +++ b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.salesforce; +package org.apache.gobblin.salesforce; import java.util.List; @@ -29,11 +29,11 @@ import org.apache.http.message.BasicNameValuePair; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.password.PasswordManager; -import gobblin.source.extractor.exception.RestApiConnectionException; -import gobblin.source.extractor.extract.restapi.RestApiConnector; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.password.PasswordManager; +import org.apache.gobblin.source.extractor.exception.RestApiConnectionException; +import org.apache.gobblin.source.extractor.extract.restapi.RestApiConnector; import lombok.Getter; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java index 4584849..4498d72 100644 --- a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java +++ b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.salesforce; +package org.apache.gobblin.salesforce; import java.io.BufferedReader; import java.io.ByteArrayInputStream; @@ -57,30 +57,30 @@ import com.sforce.async.QueryResultList; import com.sforce.soap.partner.PartnerConnection; import com.sforce.ws.ConnectorConfig; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.password.PasswordManager; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.exception.HighWatermarkException; -import gobblin.source.extractor.exception.RecordCountException; -import gobblin.source.extractor.exception.RestApiClientException; -import gobblin.source.extractor.exception.RestApiConnectionException; -import gobblin.source.extractor.exception.SchemaException; -import gobblin.source.extractor.extract.Command; -import gobblin.source.extractor.extract.CommandOutput; -import gobblin.source.jdbc.SqlQueryUtils; -import gobblin.source.extractor.extract.restapi.RestApiCommand; -import gobblin.source.extractor.extract.restapi.RestApiCommand.RestApiCommandType; -import gobblin.source.extractor.extract.restapi.RestApiConnector; -import gobblin.source.extractor.extract.restapi.RestApiExtractor; -import gobblin.source.extractor.resultset.RecordSet; -import gobblin.source.extractor.resultset.RecordSetList; -import gobblin.source.extractor.schema.Schema; -import gobblin.source.extractor.utils.InputStreamCSVReader; -import gobblin.source.extractor.utils.Utils; -import gobblin.source.extractor.watermark.Predicate; -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.password.PasswordManager; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.exception.HighWatermarkException; +import org.apache.gobblin.source.extractor.exception.RecordCountException; +import org.apache.gobblin.source.extractor.exception.RestApiClientException; +import org.apache.gobblin.source.extractor.exception.RestApiConnectionException; +import org.apache.gobblin.source.extractor.exception.SchemaException; +import org.apache.gobblin.source.extractor.extract.Command; +import org.apache.gobblin.source.extractor.extract.CommandOutput; +import org.apache.gobblin.source.jdbc.SqlQueryUtils; +import org.apache.gobblin.source.extractor.extract.restapi.RestApiCommand; +import org.apache.gobblin.source.extractor.extract.restapi.RestApiCommand.RestApiCommandType; +import org.apache.gobblin.source.extractor.extract.restapi.RestApiConnector; +import org.apache.gobblin.source.extractor.extract.restapi.RestApiExtractor; +import org.apache.gobblin.source.extractor.resultset.RecordSet; +import org.apache.gobblin.source.extractor.resultset.RecordSetList; +import org.apache.gobblin.source.extractor.schema.Schema; +import org.apache.gobblin.source.extractor.utils.InputStreamCSVReader; +import org.apache.gobblin.source.extractor.utils.Utils; +import org.apache.gobblin.source.extractor.watermark.Predicate; +import org.apache.gobblin.source.extractor.watermark.WatermarkType; +import org.apache.gobblin.source.workunit.WorkUnit; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java ---------------------------------------------------------------------- diff --git a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java index ac90a33..3b6b729 100644 --- a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java +++ b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.salesforce; +package org.apache.gobblin.salesforce; import java.io.IOException; import java.math.RoundingMode; @@ -43,25 +43,25 @@ import com.google.gson.JsonArray; import com.google.gson.JsonElement; import com.google.gson.JsonObject; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -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.RestApiClientException; -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.QueryBasedSource; -import gobblin.source.extractor.extract.restapi.RestApiConnector; -import gobblin.source.extractor.partition.Partition; -import gobblin.source.extractor.partition.Partitioner; -import gobblin.source.extractor.utils.Utils; -import gobblin.source.extractor.watermark.WatermarkType; -import gobblin.source.workunit.WorkUnit; +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.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.exception.ExtractPrepareException; +import org.apache.gobblin.source.extractor.exception.RestApiClientException; +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.QueryBasedSource; +import org.apache.gobblin.source.extractor.extract.restapi.RestApiConnector; +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.extractor.watermark.WatermarkType; +import org.apache.gobblin.source.workunit.WorkUnit; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java b/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java index 68f7f94..958034a 100644 --- a/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java +++ b/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java @@ -1,4 +1,4 @@ -package gobblin.salesforce; +package org.apache.gobblin.salesforce; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java b/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java index e144e3d..4f01623 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; import com.google.common.annotations.VisibleForTesting; import java.util.UUID; @@ -28,7 +28,7 @@ import org.apache.helix.model.HelixConfigScope; import org.apache.helix.model.Message; import org.apache.helix.tools.ClusterSetup; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; import org.slf4j.Logger; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java b/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java index 1f9132b..76ed90a 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; -import gobblin.annotation.Alpha; -import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; -import gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler; -import gobblin.service.modules.topology.ConfigBasedTopologySpecFactory; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; +import org.apache.gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler; +import org.apache.gobblin.service.modules.topology.ConfigBasedTopologySpecFactory; @Alpha public class ServiceConfigKeys { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java b/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java index f830ec8..d1fb711 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; public class ServiceMetricNames { private static final String GOBBLIN_SERVICE_PREFIX = "gobblin.service."; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java index d5515f5..6aed51e 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.service.modules.core; +package org.apache.gobblin.service.modules.core; -import gobblin.service.FlowId; -import gobblin.service.Schedule; +import org.apache.gobblin.service.FlowId; +import org.apache.gobblin.service.Schedule; import java.io.IOException; import java.lang.reflect.InvocationTargetException; import java.net.URI; @@ -68,28 +68,28 @@ import com.linkedin.restli.server.resources.BaseResource; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.restli.EmbeddedRestliServer; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.app.ApplicationException; -import gobblin.runtime.app.ApplicationLauncher; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.spec_catalog.FlowCatalog; -import gobblin.scheduler.SchedulerService; -import gobblin.service.FlowConfig; -import gobblin.service.FlowConfigClient; -import gobblin.service.FlowConfigsResource; -import gobblin.service.HelixUtils; -import gobblin.service.ServiceConfigKeys; -import gobblin.service.modules.orchestration.Orchestrator; -import gobblin.service.modules.scheduler.GobblinServiceJobScheduler; -import gobblin.service.modules.topology.TopologySpecFactory; -import gobblin.runtime.spec_catalog.TopologyCatalog; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.restli.EmbeddedRestliServer; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.app.ApplicationException; +import org.apache.gobblin.runtime.app.ApplicationLauncher; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.spec_catalog.FlowCatalog; +import org.apache.gobblin.scheduler.SchedulerService; +import org.apache.gobblin.service.FlowConfig; +import org.apache.gobblin.service.FlowConfigClient; +import org.apache.gobblin.service.FlowConfigsResource; +import org.apache.gobblin.service.HelixUtils; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.service.modules.orchestration.Orchestrator; +import org.apache.gobblin.service.modules.scheduler.GobblinServiceJobScheduler; +import org.apache.gobblin.service.modules.topology.TopologySpecFactory; +import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; @Alpha http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java index 7329a74..e8e042e 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service.modules.flow; +package org.apache.gobblin.service.modules.flow; import java.io.IOException; import java.net.URI; @@ -39,25 +39,25 @@ import com.google.common.collect.Maps; import com.typesafe.config.Config; import com.typesafe.config.ConfigValueFactory; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.JobTemplate; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecCompiler; -import gobblin.runtime.api.SpecExecutorInstance; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.job_catalog.FSJobCatalog; -import gobblin.runtime.job_spec.ResolvedJobSpec; -import gobblin.service.ServiceConfigKeys; -import gobblin.service.ServiceMetricNames; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobTemplate; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecCompiler; +import org.apache.gobblin.runtime.api.SpecExecutorInstance; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.job_catalog.FSJobCatalog; +import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.service.ServiceMetricNames; +import org.apache.gobblin.util.ConfigUtils; /*** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java index 1228d1b..7f2493a 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service.modules.orchestration; +package org.apache.gobblin.service.modules.orchestration; import java.lang.reflect.InvocationTargetException; import java.net.URI; @@ -35,24 +35,24 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Optional; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.instrumented.Instrumented; -import gobblin.instrumented.Instrumentable; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; - -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.api.SpecCompiler; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecCatalogListener; -import gobblin.runtime.spec_catalog.TopologyCatalog; -import gobblin.service.ServiceConfigKeys; -import gobblin.service.ServiceMetricNames; -import gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; + +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.api.SpecCompiler; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecCatalogListener; +import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.service.ServiceMetricNames; +import org.apache.gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; import org.slf4j.LoggerFactory; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java index 34565c6..f6f101b 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service.modules.scheduler; +package org.apache.gobblin.service.modules.scheduler; import java.net.URI; import java.util.Collection; @@ -40,22 +40,22 @@ import com.google.common.base.Optional; import com.google.common.collect.Maps; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.JobException; -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecCatalogListener; -import gobblin.runtime.listeners.JobListener; -import gobblin.runtime.spec_catalog.FlowCatalog; -import gobblin.runtime.spec_catalog.TopologyCatalog; -import gobblin.scheduler.BaseGobblinJob; -import gobblin.scheduler.JobScheduler; -import gobblin.scheduler.SchedulerService; -import gobblin.service.HelixUtils; -import gobblin.service.ServiceConfigKeys; -import gobblin.service.modules.orchestration.Orchestrator; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.JobException; +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecCatalogListener; +import org.apache.gobblin.runtime.listeners.JobListener; +import org.apache.gobblin.runtime.spec_catalog.FlowCatalog; +import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog; +import org.apache.gobblin.scheduler.BaseGobblinJob; +import org.apache.gobblin.scheduler.JobScheduler; +import org.apache.gobblin.scheduler.SchedulerService; +import org.apache.gobblin.service.HelixUtils; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.service.modules.orchestration.Orchestrator; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java index 42046a5..1a9b8f6 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service.modules.topology; +package org.apache.gobblin.service.modules.topology; import java.lang.reflect.InvocationTargetException; import java.util.Collection; @@ -31,12 +31,12 @@ import com.google.common.base.Splitter; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.runtime.api.TopologySpec; -import gobblin.service.ServiceConfigKeys; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; @Alpha http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java index 0111c3a..f57195b 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.service.modules.topology; +package org.apache.gobblin.service.modules.topology; import java.util.Collection; -import gobblin.annotation.Alpha; -import gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.api.TopologySpec; /*** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java index 585a935..a468477 100644 --- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java +++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.service.modules.core; +package org.apache.gobblin.service.modules.core; -import gobblin.service.FlowId; -import gobblin.service.Schedule; +import org.apache.gobblin.service.FlowId; +import org.apache.gobblin.service.Schedule; import java.io.File; import java.util.Map; import java.util.Properties; @@ -41,19 +41,19 @@ import com.google.gson.GsonBuilder; import com.linkedin.data.template.StringMap; import com.linkedin.restli.client.RestLiResponseException; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.runtime.spec_catalog.FlowCatalog; -import gobblin.runtime.spec_catalog.TopologyCatalog; -import gobblin.service.FlowConfig; -import gobblin.service.FlowConfigClient; -import gobblin.service.FlowId; -import gobblin.service.HelixUtils; -import gobblin.service.ServiceConfigKeys; -import gobblin.service.modules.orchestration.Orchestrator; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.runtime.spec_catalog.FlowCatalog; +import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog; +import org.apache.gobblin.service.FlowConfig; +import org.apache.gobblin.service.FlowConfigClient; +import org.apache.gobblin.service.FlowId; +import org.apache.gobblin.service.HelixUtils; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.service.modules.orchestration.Orchestrator; +import org.apache.gobblin.util.ConfigUtils; public class GobblinServiceHATest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java index 3d79606..835588d 100644 --- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java +++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.service.modules.core; +package org.apache.gobblin.service.modules.core; -import gobblin.service.FlowId; -import gobblin.service.Schedule; +import org.apache.gobblin.service.FlowId; +import org.apache.gobblin.service.Schedule; import java.io.File; import java.util.Map; import java.util.Properties; @@ -40,18 +40,18 @@ import com.google.gson.GsonBuilder; import com.linkedin.data.template.StringMap; import com.linkedin.restli.client.RestLiResponseException; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.runtime.spec_catalog.FlowCatalog; -import gobblin.runtime.spec_catalog.TopologyCatalog; -import gobblin.service.FlowConfig; -import gobblin.service.FlowConfigClient; -import gobblin.service.FlowId; -import gobblin.service.ServiceConfigKeys; -import gobblin.service.modules.orchestration.Orchestrator; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.runtime.spec_catalog.FlowCatalog; +import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog; +import org.apache.gobblin.service.FlowConfig; +import org.apache.gobblin.service.FlowConfigClient; +import org.apache.gobblin.service.FlowId; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.service.modules.orchestration.Orchestrator; +import org.apache.gobblin.util.ConfigUtils; public class GobblinServiceManagerTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java index d5155df..0b3dc15 100644 --- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java +++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.service.modules.core; +package org.apache.gobblin.service.modules.core; import java.io.File; import java.net.URI; @@ -35,17 +35,17 @@ import org.testng.annotations.Test; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; -import gobblin.service.ServiceConfigKeys; -import gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler; -import gobblin.util.ConfigUtils; -import gobblin.util.PathUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PathUtils; public class IdentityFlowToJobSpecCompilerTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java index 8cf4c09..eb9974a 100644 --- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java +++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service.modules.orchestration; +package org.apache.gobblin.service.modules.orchestration; import java.io.File; import java.net.URI; @@ -38,18 +38,18 @@ import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.typesafe.config.Config; -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecCompiler; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.runtime.spec_catalog.FlowCatalog; -import gobblin.runtime.spec_catalog.TopologyCatalog; -import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; -import gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler; -import gobblin.util.ConfigUtils; -import gobblin.util.PathUtils; +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecCompiler; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.runtime.spec_catalog.FlowCatalog; +import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog; +import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer; +import org.apache.gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PathUtils; public class OrchestratorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java index e019260..c28e97b 100644 --- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java +++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service.modules.topology; +package org.apache.gobblin.service.modules.topology; import java.util.Collection; import java.util.Iterator; @@ -28,10 +28,10 @@ import org.testng.annotations.Test; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.TopologySpec; -import gobblin.service.ServiceConfigKeys; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.service.ServiceConfigKeys; +import org.apache.gobblin.util.ConfigUtils; public class ConfigBasedTopologySpecFactoryTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java index 0822beb..b5da141 100644 --- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java +++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.test.execution.operator; +package org.apache.gobblin.test.execution.operator; /** * An interface for defining the operator , the operator could be a copy of file or converting a file from one format to another. These operators are used for the setup phase of the test http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java index c0aca77..92cc73c 100644 --- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java +++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test.execution.validator; +package org.apache.gobblin.test.execution.validator; /** * An interface is for defining the validator for the test. The input can be the set of input files and the output will be be output of http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java index 24f5151..9da7a0d 100644 --- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java +++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.test.setup.config; +package org.apache.gobblin.test.setup.config; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java index 849f715..66910b1 100644 --- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java +++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.test.setup.config; +package org.apache.gobblin.test.setup.config; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java index 853f5e9..4655178 100644 --- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java +++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test.setup.config; +package org.apache.gobblin.test.setup.config; /** * An interface for parsing the config data for test harness. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java index a05fc34..47b0c9e 100644 --- a/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java +++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java @@ -7,9 +7,9 @@ import java.util.UUID; import org.apache.commons.io.FileUtils; -import gobblin.runtime.app.ApplicationLauncher; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.runtime.local.LocalJobLauncher; +import org.apache.gobblin.runtime.app.ApplicationLauncher; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.runtime.local.LocalJobLauncher; public class GobblinLocalJobLauncherUtils { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java index 95a9ace..f553df9 100644 --- a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java +++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java @@ -16,10 +16,10 @@ import org.apache.avro.mapred.FsInput; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; +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; public class TestAvroExtractor implements Extractor<Schema, GenericRecord> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java index dbdb567..8605181 100644 --- a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java +++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java @@ -7,11 +7,11 @@ import java.util.List; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.Source; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; public class TestAvroSource implements Source<Schema, GenericRecord> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java index ef0ac46..5c1adee 100644 --- a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java +++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java @@ -21,9 +21,9 @@ import java.util.Collection; import org.testng.Assert; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.publisher.DataPublisher; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.publisher.DataPublisher; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java index 1632b72..1b2d790 100644 --- a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java +++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java @@ -22,12 +22,12 @@ import java.util.List; import org.testng.Assert; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.Source; -import gobblin.source.extractor.DummyExtractor; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.DummyExtractor; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java index 1222cd1..a44074d 100644 --- a/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java +++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java @@ -9,8 +9,8 @@ import org.testng.annotations.AfterTest; import org.testng.annotations.BeforeTest; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.hive.HiveSerDeWrapper; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.hive.HiveSerDeWrapper; public class WriterOutputFormatIntegrationTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java index e82845e..e5de71c 100644 --- a/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java +++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.test.integration.data.management; +package org.apache.gobblin.test.integration.data.management; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.JobLauncher; -import gobblin.runtime.JobLauncherFactory; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.JobLauncher; +import org.apache.gobblin.runtime.JobLauncherFactory; import java.io.FileReader; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java index 1dfc64d..606f870 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; /** * Every call takes a certain amount of time. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java index 664c91b..e9d69d5 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.util.Random; import java.util.regex.Pattern; @@ -24,7 +24,7 @@ import com.typesafe.config.Config; import lombok.Builder; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java index 8dd68b4..97be6e6 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; /** * Every nth call has a different latency than the default latency http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java index b550d68..a583198 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.io.IOException; import java.net.ServerSocket; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java index 798e11c..4bd7cec 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; /** * A class to manage timing based testing. Supports both sync and async latency decisions. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java index 0080b4f..fe651b2 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; /** * A class to hold the result of a latency decision in a testing context. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java index 1192bdb..69253f9 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; /** * An interface that provides the latency of the next call. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java index 1cd9ae0..6485ee0 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.test.crypto; +package org.apache.gobblin.test.crypto; import java.io.FilterInputStream; import java.io.FilterOutputStream; @@ -23,7 +23,7 @@ import java.io.InputStream; import java.io.OutputStream; import java.util.Map; -import gobblin.codec.StreamCodec; +import org.apache.gobblin.codec.StreamCodec; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java index 1a937fe..fe813c9 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.test.crypto; +package org.apache.gobblin.test.crypto; import java.util.Map; -import gobblin.codec.StreamCodec; -import gobblin.crypto.CredentialStore; -import gobblin.crypto.CredentialStoreProvider; -import gobblin.crypto.EncryptionProvider; +import org.apache.gobblin.codec.StreamCodec; +import org.apache.gobblin.crypto.CredentialStore; +import org.apache.gobblin.crypto.CredentialStoreProvider; +import org.apache.gobblin.crypto.EncryptionProvider; public class TestEncryptionProvider implements CredentialStoreProvider, EncryptionProvider { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java index 41d9c62..a089053 100644 --- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java +++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.test.crypto; +package org.apache.gobblin.test.crypto; import java.util.Collections; import java.util.HashMap; import java.util.Map; import java.util.Random; -import gobblin.crypto.CredentialStore; +import org.apache.gobblin.crypto.CredentialStore; public class TestRandomCredentialStore implements CredentialStore { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java b/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java index 8e5d697..5e8a8f8 100644 --- a/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java +++ b/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java ---------------------------------------------------------------------- diff --git a/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java b/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java index dc64055..0a6f4ad 100644 --- a/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java +++ b/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.test; +package org.apache.gobblin.test; import java.util.Map; @@ -23,9 +23,9 @@ import org.testng.annotations.Test; import com.google.common.collect.ImmutableMap; -import gobblin.crypto.CredentialStore; -import gobblin.test.crypto.TestEncryptionProvider; -import gobblin.test.crypto.TestRandomCredentialStore; +import org.apache.gobblin.crypto.CredentialStore; +import org.apache.gobblin.test.crypto.TestEncryptionProvider; +import org.apache.gobblin.test.crypto.TestRandomCredentialStore; public class RandomCredentialStoreTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java index 1ec36d1..9ade2ea 100644 --- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java +++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.tunnel; +package org.apache.gobblin.tunnel; import java.io.IOException; import java.nio.channels.Selector; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java ---------------------------------------------------------------------- diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java index 7e84649..03735cb 100644 --- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java +++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.tunnel; +package org.apache.gobblin.tunnel; class Config { public static final int PROXY_CONNECT_TIMEOUT_MS = 5000; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java ---------------------------------------------------------------------- diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java index 827af0a..387f249 100644 --- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java +++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.tunnel; +package org.apache.gobblin.tunnel; /** * Represents the different states a given handler can be in. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java index 5e8a462..d983a41 100644 --- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java +++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.tunnel; +package org.apache.gobblin.tunnel; import java.io.IOException; import java.net.InetSocketAddress; @@ -31,7 +31,7 @@ import java.util.concurrent.Callable; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java index effff6a..a2aab1a 100644 --- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java +++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.tunnel; +package org.apache.gobblin.tunnel; import java.io.IOException; import java.io.OutputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java ---------------------------------------------------------------------- diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java index 29ec77f..c1866fd 100644 --- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java +++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.tunnel; +package org.apache.gobblin.tunnel; import java.io.IOException; import java.net.InetSocketAddress; @@ -29,7 +29,7 @@ import java.util.concurrent.Callable; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.ExecutorsUtils; /**
