http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java index b0c7d6c..5dee390 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.StringReader; import java.util.Properties; @@ -24,13 +24,13 @@ import org.testng.Assert; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.workunit.WorkUnit; -import gobblin.test.TestSource; -import gobblin.writer.Destination; -import gobblin.writer.WriterOutputFormat; -import gobblin.util.JobLauncherUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.test.TestSource; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.WriterOutputFormat; +import org.apache.gobblin.util.JobLauncherUtils; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java index 51202a3..fa917fd 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.IOException; import java.util.ArrayList; @@ -45,26 +45,26 @@ import com.google.common.collect.Lists; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.fork.IdentityForkOperator; -import gobblin.publisher.TaskPublisher; -import gobblin.qualitychecker.row.RowLevelPolicyChecker; -import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults; -import gobblin.qualitychecker.task.TaskLevelPolicyChecker; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.DefaultCheckpointableWatermark; -import gobblin.source.extractor.Extractor; -import gobblin.stream.RecordEnvelope; -import gobblin.source.extractor.StreamingExtractor; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ExecutorsUtils; -import gobblin.writer.DataWriter; -import gobblin.writer.WatermarkAwareWriter; -import gobblin.writer.WatermarkStorage; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.fork.IdentityForkOperator; +import org.apache.gobblin.publisher.TaskPublisher; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker; +import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults; +import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.extractor.StreamingExtractor; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.WatermarkAwareWriter; +import org.apache.gobblin.writer.WatermarkStorage; import static org.mockito.Matchers.any; import static org.mockito.Matchers.anyInt; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java index 83f3a15..a0731eb 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.IOException; import java.util.Map; @@ -33,8 +33,8 @@ import com.google.common.collect.Maps; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; -import gobblin.metastore.FsStateStore; -import gobblin.util.JobLauncherUtils; +import org.apache.gobblin.metastore.FsStateStore; +import org.apache.gobblin.util.JobLauncherUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java index 67e311e..94fd4ea 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; @@ -29,9 +29,9 @@ import org.testng.annotations.Test; import com.google.common.io.Closer; -import gobblin.rest.TaskExecutionInfo; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.rest.TaskExecutionInfo; +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-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java index 834e1f94..184943d 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import static org.mockito.Matchers.any; import static org.mockito.Matchers.anyInt; @@ -47,22 +47,22 @@ import com.google.common.collect.Lists; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.fork.ForkOperator; -import gobblin.fork.IdentityForkOperator; -import gobblin.publisher.TaskPublisher; -import gobblin.qualitychecker.row.RowLevelPolicyCheckResults; -import gobblin.qualitychecker.row.RowLevelPolicyChecker; -import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults; -import gobblin.qualitychecker.task.TaskLevelPolicyChecker; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.WorkUnit; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.fork.ForkOperator; +import org.apache.gobblin.fork.IdentityForkOperator; +import org.apache.gobblin.publisher.TaskPublisher; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckResults; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker; +import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults; +import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java index 9181eb3..c2f0cdb 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.IOException; import java.util.ArrayList; @@ -32,28 +32,28 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.common.collect.Lists; -import gobblin.ack.BasicAckableForTesting; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.fork.IdentityForkOperator; -import gobblin.publisher.TaskPublisher; -import gobblin.qualitychecker.row.RowLevelPolicyChecker; -import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults; -import gobblin.qualitychecker.task.TaskLevelPolicyChecker; -import gobblin.records.ControlMessageHandler; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.WorkUnit; -import gobblin.stream.ControlMessage; -import gobblin.stream.FlushControlMessage; -import gobblin.stream.RecordEnvelope; -import gobblin.stream.StreamEntity; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.ack.BasicAckableForTesting; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.fork.IdentityForkOperator; +import org.apache.gobblin.publisher.TaskPublisher; +import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker; +import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults; +import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker; +import org.apache.gobblin.records.ControlMessageHandler; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.stream.ControlMessage; +import org.apache.gobblin.stream.FlushControlMessage; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.stream.StreamEntity; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; import io.reactivex.Flowable; import lombok.AllArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java index cf66a29..a1fd5ed 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.util.Iterator; import java.util.Set; @@ -31,17 +31,17 @@ import com.google.common.collect.Sets; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.runtime.api.JobExecutionDriver; -import gobblin.runtime.api.JobExecutionResult; -import gobblin.runtime.embedded.EmbeddedGobblin; -import gobblin.source.WorkUnitStreamSource; -import gobblin.source.workunit.BasicWorkUnitStream; -import gobblin.source.workunit.WorkUnit; -import gobblin.source.workunit.WorkUnitStream; -import gobblin.task.EventBusPublishingTaskFactory; -import gobblin.writer.test.TestingEventBuses; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.runtime.api.JobExecutionDriver; +import org.apache.gobblin.runtime.api.JobExecutionResult; +import org.apache.gobblin.runtime.embedded.EmbeddedGobblin; +import org.apache.gobblin.source.WorkUnitStreamSource; +import org.apache.gobblin.source.workunit.BasicWorkUnitStream; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.WorkUnitStream; +import org.apache.gobblin.task.EventBusPublishingTaskFactory; +import org.apache.gobblin.writer.test.TestingEventBuses; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java index ce85c9a..99322e0 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.api; +package org.apache.gobblin.runtime.api; -import static gobblin.configuration.ConfigurationKeys.JOB_NAME_KEY; +import static org.apache.gobblin.configuration.ConfigurationKeys.JOB_NAME_KEY; import static org.mockito.Matchers.eq; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.verify; @@ -36,11 +36,11 @@ import com.google.common.base.Predicate; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.JobState.RunningState; -import gobblin.runtime.std.JobExecutionUpdatable; -import gobblin.testing.AssertWithBackoff; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.JobState.RunningState; +import org.apache.gobblin.runtime.std.JobExecutionUpdatable; +import org.apache.gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.util.ExecutorsUtils; /** * Unit tests for {@link JobExecutionState} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java index ca8987f..2f0f2d9 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.api; +package org.apache.gobblin.runtime.api; import java.net.URI; import java.net.URISyntaxException; @@ -29,7 +29,7 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; /** * Unit tests for {@link JobSpec} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java index fc88e81..213f1e4 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.commit; +package org.apache.gobblin.runtime.commit; import java.io.IOException; @@ -27,11 +27,11 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.commit.CommitSequence; -import gobblin.commit.FsRenameCommitStep; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.runtime.JobState.DatasetState; +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.runtime.JobState.DatasetState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java index 2f03373..cd036a2 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.commit; +package org.apache.gobblin.runtime.commit; import java.io.IOException; @@ -31,14 +31,14 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.gson.Gson; -import gobblin.commit.CommitSequence; -import gobblin.commit.CommitStep; -import gobblin.commit.FsRenameCommitStep; -import gobblin.configuration.State; -import gobblin.runtime.JobState.DatasetState; -import gobblin.runtime.commit.DatasetStateCommitStep; -import gobblin.runtime.commit.FsCommitSequenceStore; -import gobblin.util.io.GsonInterfaceAdapter; +import org.apache.gobblin.commit.CommitSequence; +import org.apache.gobblin.commit.CommitStep; +import org.apache.gobblin.commit.FsRenameCommitStep; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.runtime.JobState.DatasetState; +import org.apache.gobblin.runtime.commit.DatasetStateCommitStep; +import org.apache.gobblin.runtime.commit.FsCommitSequenceStore; +import org.apache.gobblin.util.io.GsonInterfaceAdapter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java index dfe45ec..42581a9 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.embedded; +package org.apache.gobblin.runtime.embedded; import java.util.ArrayList; import java.util.List; @@ -23,12 +23,12 @@ import java.util.List; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobExecutionResult; -import gobblin.runtime.template.ResourceBasedJobTemplate; -import gobblin.util.test.HelloWorldSource; -import gobblin.writer.test.GobblinTestEventBusWriter; -import gobblin.writer.test.TestingEventBusAsserter; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobExecutionResult; +import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate; +import org.apache.gobblin.util.test.HelloWorldSource; +import org.apache.gobblin.writer.test.GobblinTestEventBusWriter; +import org.apache.gobblin.writer.test.TestingEventBusAsserter; public class EmbeddedGobblinTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java index 5f04640..de40176 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.instance; +package org.apache.gobblin.runtime.instance; import java.util.Collections; import java.util.concurrent.TimeUnit; @@ -30,18 +30,18 @@ import com.google.common.base.Predicate; import com.google.common.util.concurrent.Service.State; import com.typesafe.config.ConfigFactory; -import gobblin.metrics.MetricContext; -import gobblin.broker.SharedResourcesBrokerFactory; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.runtime.api.Configurable; -import gobblin.runtime.api.GobblinInstancePluginFactory; -import gobblin.runtime.api.JobExecutionLauncher; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.JobSpecScheduler; -import gobblin.runtime.job_catalog.InMemoryJobCatalog; -import gobblin.runtime.std.DefaultConfigurableImpl; -import gobblin.runtime.std.DefaultJobSpecScheduleImpl; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.broker.SharedResourcesBrokerFactory; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.runtime.api.Configurable; +import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory; +import org.apache.gobblin.runtime.api.JobExecutionLauncher; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpecScheduler; +import org.apache.gobblin.runtime.job_catalog.InMemoryJobCatalog; +import org.apache.gobblin.runtime.std.DefaultConfigurableImpl; +import org.apache.gobblin.runtime.std.DefaultJobSpecScheduleImpl; +import org.apache.gobblin.testing.AssertWithBackoff; /** * Unit tests for {@link DefaultGobblinInstanceDriverImpl} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java index 303f1e4..8ad9093 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.instance; +package org.apache.gobblin.runtime.instance; import java.util.HashSet; import java.util.List; @@ -28,13 +28,13 @@ import com.google.common.util.concurrent.AbstractIdleService; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.annotation.Alias; -import gobblin.runtime.api.GobblinInstanceDriver; -import gobblin.runtime.api.GobblinInstanceEnvironment; -import gobblin.runtime.api.GobblinInstancePlugin; -import gobblin.runtime.api.GobblinInstancePluginFactory; -import gobblin.runtime.plugins.email.EmailNotificationPlugin; -import gobblin.runtime.std.DefaultConfigurableImpl; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.runtime.api.GobblinInstanceDriver; +import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment; +import org.apache.gobblin.runtime.api.GobblinInstancePlugin; +import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory; +import org.apache.gobblin.runtime.plugins.email.EmailNotificationPlugin; +import org.apache.gobblin.runtime.std.DefaultConfigurableImpl; import avro.shaded.com.google.common.collect.ImmutableMap; import lombok.AllArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java index fab5de0..9b97fe9 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.instance; +package org.apache.gobblin.runtime.instance; import java.net.URI; import java.util.ArrayList; @@ -30,21 +30,21 @@ import com.google.common.base.Function; import com.google.common.collect.ImmutableMap; import com.typesafe.config.ConfigFactory; -import gobblin.runtime.api.GobblinInstanceDriver; -import gobblin.runtime.api.JobExecutionDriver; -import gobblin.runtime.api.JobExecutionLauncher; -import gobblin.runtime.api.JobExecutionResult; -import gobblin.runtime.api.JobLifecycleListener; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.instance.DefaultGobblinInstanceDriverImpl.JobSpecRunnable; -import gobblin.runtime.job_spec.ResolvedJobSpec; -import gobblin.runtime.std.DefaultJobLifecycleListenerImpl; -import gobblin.runtime.std.FilteredJobLifecycleListener; -import gobblin.runtime.std.JobSpecFilter; -import gobblin.testing.AssertWithBackoff; -import gobblin.util.test.HelloWorldSource; -import gobblin.writer.test.GobblinTestEventBusWriter; -import gobblin.writer.test.TestingEventBusAsserter; +import org.apache.gobblin.runtime.api.GobblinInstanceDriver; +import org.apache.gobblin.runtime.api.JobExecutionDriver; +import org.apache.gobblin.runtime.api.JobExecutionLauncher; +import org.apache.gobblin.runtime.api.JobExecutionResult; +import org.apache.gobblin.runtime.api.JobLifecycleListener; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.instance.DefaultGobblinInstanceDriverImpl.JobSpecRunnable; +import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec; +import org.apache.gobblin.runtime.std.DefaultJobLifecycleListenerImpl; +import org.apache.gobblin.runtime.std.FilteredJobLifecycleListener; +import org.apache.gobblin.runtime.std.JobSpecFilter; +import org.apache.gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.util.test.HelloWorldSource; +import org.apache.gobblin.writer.test.GobblinTestEventBusWriter; +import org.apache.gobblin.writer.test.TestingEventBusAsserter; /** * Unit tests for {@link StandardGobblinInstanceLauncher} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java index fb1829f..ca245eb 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java @@ -9,7 +9,7 @@ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR * CONDITIONS OF ANY KIND, either express or implied. */ -package gobblin.runtime.instance.hadoop; +package org.apache.gobblin.runtime.instance.hadoop; import org.apache.hadoop.conf.Configuration; import org.testng.Assert; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java index 0404275..c50daec 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_catalog; +package org.apache.gobblin.runtime.job_catalog; import java.io.File; import java.io.FileWriter; @@ -44,16 +44,16 @@ import com.google.common.io.Files; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.job_catalog.FSJobCatalog; -import gobblin.runtime.job_catalog.ImmutableFSJobCatalog; -import gobblin.util.ConfigUtils; -import gobblin.util.PullFileLoader; -import gobblin.util.filesystem.PathAlterationObserverScheduler; -import gobblin.util.filesystem.PathAlterationListener; -import gobblin.util.filesystem.PathAlterationListenerAdaptor; -import gobblin.util.filesystem.PathAlterationObserver; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.job_catalog.FSJobCatalog; +import org.apache.gobblin.runtime.job_catalog.ImmutableFSJobCatalog; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PullFileLoader; +import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler; +import org.apache.gobblin.util.filesystem.PathAlterationListener; +import org.apache.gobblin.util.filesystem.PathAlterationListenerAdaptor; +import org.apache.gobblin.util.filesystem.PathAlterationObserver; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java index 1324096..bf448cb 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_catalog; +package org.apache.gobblin.runtime.job_catalog; import java.net.URI; import java.util.Collection; @@ -26,10 +26,10 @@ import org.testng.annotations.Test; import com.typesafe.config.Config; -import gobblin.runtime.api.JobCatalogWithTemplates; -import gobblin.runtime.api.JobTemplate; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.template.ResourceBasedJobTemplate; +import org.apache.gobblin.runtime.api.JobCatalogWithTemplates; +import org.apache.gobblin.runtime.api.JobTemplate; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate; public class PackagedTemplatesJobCatalogDecoratorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java index caab700..149d56a 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.runtime.job_catalog; +package org.apache.gobblin.runtime.job_catalog; -import gobblin.config.ConfigBuilder; -import gobblin.runtime.job_spec.ResolvedJobSpec; +import org.apache.gobblin.config.ConfigBuilder; +import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec; import java.io.File; import java.io.PrintWriter; import java.net.URI; @@ -33,11 +33,11 @@ import org.mockito.invocation.InvocationOnMock; import org.mockito.stubbing.Answer; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobCatalogListener; -import gobblin.runtime.api.JobSpec; -import gobblin.util.ConfigUtils; -import gobblin.util.filesystem.PathAlterationObserver; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobCatalogListener; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.filesystem.PathAlterationObserver; import org.testng.Assert; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java index 72efd7a..d58cd46 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.job_catalog; +package org.apache.gobblin.runtime.job_catalog; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; @@ -28,7 +28,7 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; /** * Unit tests for {@link ImmutableFSJobCatalog} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java index 29f6ef7..5920f78 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_catalog; +package org.apache.gobblin.runtime.job_catalog; import java.net.URI; import java.util.concurrent.TimeUnit; @@ -29,12 +29,12 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.common.base.Predicates; -import gobblin.instrumented.GobblinMetricsKeys; -import gobblin.metrics.MetricContext; -import gobblin.metrics.test.MetricsAssert; -import gobblin.runtime.api.JobCatalog; -import gobblin.runtime.api.JobCatalogListener; -import gobblin.runtime.api.JobSpec; +import org.apache.gobblin.instrumented.GobblinMetricsKeys; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.test.MetricsAssert; +import org.apache.gobblin.runtime.api.JobCatalog; +import org.apache.gobblin.runtime.api.JobCatalogListener; +import org.apache.gobblin.runtime.api.JobSpec; /** Unit tests for {@link InMemoryJobCatalog} */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java index 91ef22a..8bbfdd2 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.runtime.job_catalog; +package org.apache.gobblin.runtime.job_catalog; import org.mockito.Mockito; import org.testng.annotations.Test; -import gobblin.runtime.api.JobCatalogListener; -import gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobCatalogListener; +import org.apache.gobblin.runtime.api.JobSpec; /** Unit tests for {@link JobCatalogListenersList} */ public class TestJobCatalogListenersList { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java index dabf4b2..294fece 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.job_catalog; +package org.apache.gobblin.runtime.job_catalog; import java.net.URI; import java.util.concurrent.TimeUnit; @@ -27,9 +27,9 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; -import gobblin.runtime.api.JobCatalogListener; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.JobSpecNotFoundException; +import org.apache.gobblin.runtime.api.JobCatalogListener; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpecNotFoundException; /** Unit tests for {@link CachingJobCatalog} and {@link MutableCachingJobCatalog} */ public class TestMutableCachingJobCatalog { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java index 855cf1b..3346766 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_catalog; +package org.apache.gobblin.runtime.job_catalog; import java.io.File; import java.io.PrintWriter; @@ -32,13 +32,13 @@ import org.mockito.stubbing.Answer; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.config.ConfigBuilder; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobCatalogListener; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.job_spec.ResolvedJobSpec; -import gobblin.util.ConfigUtils; -import gobblin.util.filesystem.PathAlterationObserver; +import org.apache.gobblin.config.ConfigBuilder; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobCatalogListener; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.filesystem.PathAlterationObserver; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java index 02081bb..4aa5084 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.job_exec; +package org.apache.gobblin.runtime.job_exec; import java.io.File; import java.io.IOException; @@ -30,13 +30,13 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.JobLauncherFactory; -import gobblin.runtime.api.JobExecution; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.local.LocalJobLauncher; -import gobblin.runtime.mapreduce.MRJobLauncher; -import gobblin.util.test.TestingSource; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.JobLauncherFactory; +import org.apache.gobblin.runtime.api.JobExecution; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.local.LocalJobLauncher; +import org.apache.gobblin.runtime.mapreduce.MRJobLauncher; +import org.apache.gobblin.util.test.TestingSource; /** * Unit tests for {@link JobLauncherExecutionDriver} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java index 1f38a07..416e237 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_monitor; +package org.apache.gobblin.runtime.job_monitor; import java.net.URI; import java.util.Collection; @@ -29,17 +29,17 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.Metric; -import gobblin.metrics.MetricReport; -import gobblin.metrics.reporter.util.AvroBinarySerializer; -import gobblin.metrics.reporter.util.AvroSerializer; -import gobblin.metrics.reporter.util.FixedSchemaVersionWriter; -import gobblin.metrics.reporter.util.NoopSchemaVersionWriter; -import gobblin.metrics.reporter.util.SchemaVersionWriter; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.kafka.HighLevelConsumerTest; -import gobblin.util.Either; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.Metric; +import org.apache.gobblin.metrics.MetricReport; +import org.apache.gobblin.metrics.reporter.util.AvroBinarySerializer; +import org.apache.gobblin.metrics.reporter.util.AvroSerializer; +import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter; +import org.apache.gobblin.metrics.reporter.util.NoopSchemaVersionWriter; +import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.kafka.HighLevelConsumerTest; +import org.apache.gobblin.util.Either; public class KafkaAvroJobMonitorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java index c517acc..1dd90b1 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_monitor; +package org.apache.gobblin.runtime.job_monitor; import java.net.URI; @@ -24,7 +24,7 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; -import gobblin.runtime.kafka.HighLevelConsumerTest; +import org.apache.gobblin.runtime.kafka.HighLevelConsumerTest; public class KafkaJobMonitorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java index 5644795..7787519 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_monitor; +package org.apache.gobblin.runtime.job_monitor; import java.util.List; import java.util.concurrent.BlockingQueue; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java index c127c83..7d3ef37 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_monitor; +package org.apache.gobblin.runtime.job_monitor; import java.io.IOException; import java.net.URI; @@ -38,10 +38,10 @@ import com.google.common.collect.Maps; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.MutableJobCatalog; -import gobblin.testing.AssertWithBackoff; -import gobblin.util.Either; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.MutableJobCatalog; +import org.apache.gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.util.Either; import kafka.consumer.KafkaStream; import kafka.javaapi.consumer.ConsumerConnector; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java index f4dc696..5c278c9 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.job_monitor; +package org.apache.gobblin.runtime.job_monitor; import java.net.URI; import java.util.Collection; @@ -32,13 +32,13 @@ import com.google.common.collect.Maps; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.event.sla.SlaEventKeys; -import gobblin.metrics.reporter.util.FixedSchemaVersionWriter; -import gobblin.metrics.reporter.util.NoopSchemaVersionWriter; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.kafka.HighLevelConsumerTest; -import gobblin.util.Either; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.event.sla.SlaEventKeys; +import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter; +import org.apache.gobblin.metrics.reporter.util.NoopSchemaVersionWriter; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.kafka.HighLevelConsumerTest; +import org.apache.gobblin.util.Either; public class SLAEventKafkaJobMonitorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java index 8cbdb68..6e8d7a2 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.kafka; +package org.apache.gobblin.runtime.kafka; import java.util.Properties; import java.util.concurrent.TimeoutException; @@ -27,7 +27,7 @@ import com.google.common.base.Optional; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.runtime.job_monitor.MockKafkaStream; +import org.apache.gobblin.runtime.job_monitor.MockKafkaStream; public class HighLevelConsumerTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java index d675cfc..5035afa 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.kafka; +package org.apache.gobblin.runtime.kafka; import java.util.List; @@ -26,8 +26,8 @@ import com.google.common.base.Predicate; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.runtime.job_monitor.MockKafkaStream; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.runtime.job_monitor.MockKafkaStream; +import org.apache.gobblin.testing.AssertWithBackoff; import javax.annotation.Nullable; import kafka.consumer.ConsumerConfig; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java index d446923..f620561 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.local; +package org.apache.gobblin.runtime.local; import java.io.FileReader; import java.io.IOException; @@ -25,18 +25,18 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metastore.FsStateStore; -import gobblin.metastore.StateStore; - -import gobblin.metastore.testing.ITestMetastoreDatabase; -import gobblin.metastore.testing.TestMetastoreDatabaseFactory; -import gobblin.runtime.JobLauncherTestHelper; -import gobblin.runtime.JobState; -import gobblin.util.limiter.BaseLimiterType; -import gobblin.util.limiter.DefaultLimiterFactory; -import gobblin.writer.Destination; -import gobblin.writer.WriterOutputFormat; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metastore.FsStateStore; +import org.apache.gobblin.metastore.StateStore; + +import org.apache.gobblin.metastore.testing.ITestMetastoreDatabase; +import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory; +import org.apache.gobblin.runtime.JobLauncherTestHelper; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.util.limiter.BaseLimiterType; +import org.apache.gobblin.util.limiter.DefaultLimiterFactory; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.WriterOutputFormat; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java index bcc9502..c536202 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java @@ -1,7 +1,7 @@ /** * */ -package gobblin.runtime.locks; +package org.apache.gobblin.runtime.locks; import java.io.File; @@ -17,7 +17,7 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpec; /** * Unit tests for {@link FileBasedJobLockFactoryManager} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java index 4f7a2c3..d6f1378 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.locks; +package org.apache.gobblin.runtime.locks; import java.io.IOException; import java.util.Properties; @@ -28,7 +28,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/runtime/locks/JobLockTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/JobLockTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/JobLockTest.java index 9a905c9..8d03010 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/JobLockTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/JobLockTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.locks; +package org.apache.gobblin.runtime.locks; import java.io.IOException; import java.util.concurrent.CountDownLatch; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java index f313376..6dbc17f 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.locks; +package org.apache.gobblin.runtime.locks; import java.io.IOException; import java.util.Properties; @@ -28,7 +28,7 @@ import org.testng.annotations.Test; import com.google.common.io.Closer; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; @Test(groups = {"gobblin.runtime"}) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java index 6e7718c..1fe94c9 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.locks; +package org.apache.gobblin.runtime.locks; import java.io.IOException; import java.util.Properties; @@ -25,7 +25,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; /** * Unit test for {@link ZookeeperBasedJobLock}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java index ada7480..c182dce 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.mapreduce; +package org.apache.gobblin.runtime.mapreduce; import java.io.IOException; import java.util.Arrays; @@ -35,10 +35,10 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; import com.google.common.io.Closer; -import gobblin.configuration.ConfigurationKeys; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ForkOperatorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java index 85a98b2..102c8a0 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.mapreduce; +package org.apache.gobblin.runtime.mapreduce; import java.io.ByteArrayInputStream; import java.io.DataInputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java index e5127d6..e9f6c62 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.mapreduce; +package org.apache.gobblin.runtime.mapreduce; import java.io.File; import java.io.IOException; @@ -32,18 +32,18 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metastore.FsStateStore; -import gobblin.metastore.StateStore; -import gobblin.metastore.testing.ITestMetastoreDatabase; -import gobblin.metastore.testing.TestMetastoreDatabaseFactory; -import gobblin.metrics.GobblinMetrics; -import gobblin.runtime.JobLauncherTestHelper; -import gobblin.runtime.JobState; -import gobblin.util.limiter.BaseLimiterType; -import gobblin.util.limiter.DefaultLimiterFactory; -import gobblin.writer.Destination; -import gobblin.writer.WriterOutputFormat; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metastore.FsStateStore; +import org.apache.gobblin.metastore.StateStore; +import org.apache.gobblin.metastore.testing.ITestMetastoreDatabase; +import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.runtime.JobLauncherTestHelper; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.util.limiter.BaseLimiterType; +import org.apache.gobblin.util.limiter.DefaultLimiterFactory; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.WriterOutputFormat; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java index 7774056..a1e91f1 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java @@ -15,22 +15,22 @@ * limitations under the License. */ -package gobblin.runtime.mapreduce; +package org.apache.gobblin.runtime.mapreduce; import com.google.common.base.Charsets; import com.google.common.base.Splitter; import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.runtime.api.JobExecutionResult; -import gobblin.runtime.embedded.EmbeddedGobblin; -import gobblin.runtime.task.TaskUtils; -import gobblin.source.Source; -import gobblin.source.extractor.Extractor; -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.runtime.api.JobExecutionResult; +import org.apache.gobblin.runtime.embedded.EmbeddedGobblin; +import org.apache.gobblin.runtime.task.TaskUtils; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; import java.io.File; import java.io.IOException; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java index eaefc62..cc1720d 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.scheduler; +package org.apache.gobblin.runtime.scheduler; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.verify; @@ -30,9 +30,9 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.JobSpecSchedule; -import gobblin.runtime.api.JobSpecSchedulerListener; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpecSchedule; +import org.apache.gobblin.runtime.api.JobSpecSchedulerListener; /** * Unit tests for {@link ImmediateJobSpecScheduler} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java index 8eb5cdf..b51d362 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.scheduler; +package org.apache.gobblin.runtime.scheduler; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.TimeUnit; @@ -28,10 +28,10 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.JobSpecSchedule; -import gobblin.runtime.scheduler.QuartzJobSpecScheduler.QuartzJobSchedule; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpecSchedule; +import org.apache.gobblin.runtime.scheduler.QuartzJobSpecScheduler.QuartzJobSchedule; /** * Unit tests for {@link QuartzJobSpecScheduler}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java index 0d7fd71..ae47536 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.util.Properties; @@ -26,7 +26,7 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.runtime.std.DefaultConfigurableImpl; +import org.apache.gobblin.runtime.std.DefaultConfigurableImpl; /** * Unit tests for {@link DefaultConfigurableImpl} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java index 865df22..467d835 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import static org.mockito.Matchers.eq; import static org.mockito.Mockito.mock; @@ -28,12 +28,12 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.JobState.RunningState; -import gobblin.runtime.api.JobExecutionState; -import gobblin.runtime.api.JobExecutionStateListener; -import gobblin.runtime.api.JobLifecycleListener; -import gobblin.runtime.api.JobSpec; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.JobState.RunningState; +import org.apache.gobblin.runtime.api.JobExecutionState; +import org.apache.gobblin.runtime.api.JobExecutionStateListener; +import org.apache.gobblin.runtime.api.JobLifecycleListener; +import org.apache.gobblin.runtime.api.JobSpec; /** * Unit tests for {@link FilteredJobLifecycleListener} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java index 826fe6b..e746cfd 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import org.mockito.Mockito; import org.slf4j.Logger; @@ -25,11 +25,11 @@ import com.google.common.base.Optional; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.JobState.RunningState; -import gobblin.runtime.api.JobExecutionState; -import gobblin.runtime.api.JobExecutionStateListener; -import gobblin.runtime.api.JobSpec; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.JobState.RunningState; +import org.apache.gobblin.runtime.api.JobExecutionState; +import org.apache.gobblin.runtime.api.JobExecutionStateListener; +import org.apache.gobblin.runtime.api.JobSpec; /** * Unit tests for {@link JobExecutionStateListeners}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java index bd6dfac..24ed6c4 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import static org.mockito.Matchers.eq; import static org.mockito.Mockito.mock; @@ -25,11 +25,11 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.testng.annotations.Test; -import gobblin.runtime.api.JobCatalogListenersContainer; -import gobblin.runtime.api.JobExecutionDriver; -import gobblin.runtime.api.JobExecutionState; -import gobblin.runtime.api.JobLifecycleListener; -import gobblin.runtime.api.JobSpecSchedulerListenersContainer; +import org.apache.gobblin.runtime.api.JobCatalogListenersContainer; +import org.apache.gobblin.runtime.api.JobExecutionDriver; +import org.apache.gobblin.runtime.api.JobExecutionState; +import org.apache.gobblin.runtime.api.JobLifecycleListener; +import org.apache.gobblin.runtime.api.JobSpecSchedulerListenersContainer; /** * Unit tests for {@link JobLifecycleListenersList} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java index 6b3cb69..54f28b2 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpec; /** * Unit tests for {@link JobSpecFilter} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java index 4a12c5f..ab76f18 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.template; +package org.apache.gobblin.runtime.template; import java.net.URI; import java.net.URISyntaxException; @@ -36,9 +36,9 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigException; import com.typesafe.config.ConfigFactory; -import gobblin.runtime.api.JobCatalogWithTemplates; -import gobblin.runtime.api.JobTemplate; -import gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.api.JobCatalogWithTemplates; +import org.apache.gobblin.runtime.api.JobTemplate; +import org.apache.gobblin.runtime.api.SpecNotFoundException; import lombok.AllArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java index 9429d69..7864658 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.template; +package org.apache.gobblin.runtime.template; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java index 50206c3..ce42f8e 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.template; +package org.apache.gobblin.runtime.template; import java.net.URI; import java.util.Collection; @@ -31,8 +31,8 @@ import com.google.common.collect.Maps; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobCatalogWithTemplates; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobCatalogWithTemplates; public class StaticJobTemplateTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java index 0c3b329..8a21d58 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import java.util.List; import java.util.Map; @@ -27,13 +27,13 @@ import org.testng.annotations.Test; import com.google.common.collect.ImmutableList; import com.google.common.collect.Iterables; -import gobblin.configuration.State; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.GobblinMetricsRegistry; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.metrics.event.JobEvent; -import gobblin.runtime.JobState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.GobblinMetricsRegistry; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.event.JobEvent; +import org.apache.gobblin.runtime.JobState; @Test(groups = { "gobblin.runtime" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java index 07ce7c4..a195ff4 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import com.google.gson.JsonElement; import com.google.gson.JsonObject; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java index 4f933ab..1d2fd82 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import com.google.common.base.Function; import com.google.common.collect.Iterators; import com.google.common.collect.Lists; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; import java.util.List; import javax.annotation.Nullable; import org.testng.Assert; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java index 1b0c6fc..6ea2997 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import java.util.ArrayList; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.runtime.JobState; -import gobblin.runtime.TaskState; -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.runtime.JobState; +import org.apache.gobblin.runtime.TaskState; +import org.apache.gobblin.source.workunit.WorkUnit; @Test(groups = {"gobblin.runtime"})
