http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHierarchicalPrioritizer.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHierarchicalPrioritizer.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHierarchicalPrioritizer.java index 7a6281f..a6adc72 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHierarchicalPrioritizer.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHierarchicalPrioritizer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.io.Serializable; import java.util.Comparator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/VectorAlgebra.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/VectorAlgebra.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/VectorAlgebra.java index d26b98b..04859b3 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/VectorAlgebra.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/VectorAlgebra.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; /** * Basic vector operations. These operations are NOT safe (e.g. no bound checks on vectors), so they are package-private. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/service/StandardServiceConfig.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/service/StandardServiceConfig.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/service/StandardServiceConfig.java index d4055f9..056b254 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/service/StandardServiceConfig.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/service/StandardServiceConfig.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util.service; +package org.apache.gobblin.util.service; import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/test/FastSequentialSource.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/test/FastSequentialSource.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/test/FastSequentialSource.java index c0d98f1..add4220 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/test/FastSequentialSource.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/test/FastSequentialSource.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import java.io.IOException; import java.util.List; import com.google.common.collect.Lists; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.Source; -import gobblin.source.extractor.DataRecordException; -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.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; import lombok.RequiredArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/test/HelloWorldSource.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/test/HelloWorldSource.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/test/HelloWorldSource.java index 9cd08e0..2cfca47 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/test/HelloWorldSource.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/test/HelloWorldSource.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import java.io.IOException; import java.util.ArrayList; @@ -23,14 +23,14 @@ import java.util.List; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.Source; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.Extract.TableType; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ConfigUtils; +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.Extract; +import org.apache.gobblin.source.workunit.Extract.TableType; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ConfigUtils; /** * Hello world! http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/test/StdoutWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/test/StdoutWriter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/test/StdoutWriter.java index ec57c00..7e9297a 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/test/StdoutWriter.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/test/StdoutWriter.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import java.io.IOException; import java.nio.charset.Charset; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; /** * A simple writer implementation that writes the output to Stdout http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/test/TestingSource.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/test/TestingSource.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/test/TestingSource.java index 208212e..b9fcc09 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/test/TestingSource.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/test/TestingSource.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import java.io.IOException; import java.util.ArrayList; import java.util.List; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.Source; -import gobblin.source.extractor.DataRecordException; -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.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; import lombok.Getter; import lombok.Setter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/AutoscopedFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/AutoscopedFactoryTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/AutoscopedFactoryTest.java index e0d3a5b..cc5af6b 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/AutoscopedFactoryTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/AutoscopedFactoryTest.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.gobblin_scopes.JobScopeInstance; -import gobblin.broker.gobblin_scopes.TaskScopeInstance; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.gobblin_scopes.JobScopeInstance; +import org.apache.gobblin.broker.gobblin_scopes.TaskScopeInstance; public class AutoscopedFactoryTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/DefaultGobblinBrokerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/DefaultGobblinBrokerTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/DefaultGobblinBrokerTest.java index 043cd79..477032b 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/DefaultGobblinBrokerTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/DefaultGobblinBrokerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; import java.util.Random; @@ -27,17 +27,17 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.broker.gobblin_scopes.GobblinScopeInstance; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.gobblin_scopes.JobScopeInstance; -import gobblin.broker.gobblin_scopes.TaskScopeInstance; -import gobblin.broker.iface.ConfigView; -import gobblin.broker.iface.NoSuchScopeException; -import gobblin.broker.iface.NotConfiguredException; -import gobblin.broker.iface.ScopedConfigView; -import gobblin.broker.iface.SharedResourceFactory; -import gobblin.broker.iface.SharedResourceFactoryResponse; -import gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeInstance; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.gobblin_scopes.JobScopeInstance; +import org.apache.gobblin.broker.gobblin_scopes.TaskScopeInstance; +import org.apache.gobblin.broker.iface.ConfigView; +import org.apache.gobblin.broker.iface.NoSuchScopeException; +import org.apache.gobblin.broker.iface.NotConfiguredException; +import org.apache.gobblin.broker.iface.ScopedConfigView; +import org.apache.gobblin.broker.iface.SharedResourceFactory; +import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; import lombok.Data; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerConfTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerConfTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerConfTest.java index f5a7d5c..3d2803c 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerConfTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerConfTest.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.gobblin_scopes.JobScopeInstance; -import gobblin.broker.iface.ScopedConfigView; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.gobblin_scopes.JobScopeInstance; +import org.apache.gobblin.broker.iface.ScopedConfigView; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerCreationTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerCreationTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerCreationTest.java index 792d733..61b1e89 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerCreationTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/GobblinBrokerCreationTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; import org.testng.Assert; import org.testng.annotations.Test; @@ -23,10 +23,10 @@ import org.testng.annotations.Test; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.broker.gobblin_scopes.GobblinScopeInstance; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.gobblin_scopes.JobScopeInstance; -import gobblin.broker.gobblin_scopes.TaskScopeInstance; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeInstance; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.gobblin_scopes.JobScopeInstance; +import org.apache.gobblin.broker.gobblin_scopes.TaskScopeInstance; public class GobblinBrokerCreationTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/KeyedScopedConfigViewImplTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/KeyedScopedConfigViewImplTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/KeyedScopedConfigViewImplTest.java index ea70ee8..6adaa21 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/KeyedScopedConfigViewImplTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/KeyedScopedConfigViewImplTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; import org.testng.Assert; import org.testng.annotations.Test; @@ -25,7 +25,7 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; public class KeyedScopedConfigViewImplTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/SharedResourcesBrokerFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/SharedResourcesBrokerFactoryTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/SharedResourcesBrokerFactoryTest.java index 2a2858f..1b1c3e8 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/SharedResourcesBrokerFactoryTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/SharedResourcesBrokerFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; @@ -29,8 +29,8 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.broker.iface.ConfigView; -import gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.broker.iface.ConfigView; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; import lombok.RequiredArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactory.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactory.java index 8cd5a3e..9fcdd23 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactory.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactory.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; -import gobblin.broker.iface.SharedResourceFactoryResponse; +import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse; import java.io.Closeable; import java.io.IOException; import java.util.Random; @@ -27,12 +27,12 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.ConfigView; -import gobblin.broker.iface.ScopeType; -import gobblin.broker.iface.ScopedConfigView; -import gobblin.broker.iface.SharedResourceFactory; -import gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.ConfigView; +import org.apache.gobblin.broker.iface.ScopeType; +import org.apache.gobblin.broker.iface.ScopedConfigView; +import org.apache.gobblin.broker.iface.SharedResourceFactory; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactoryWithRedirect.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactoryWithRedirect.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactoryWithRedirect.java index e436ff3..bd52414 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactoryWithRedirect.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestFactoryWithRedirect.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; -import gobblin.broker.iface.ScopeType; -import gobblin.broker.iface.ScopedConfigView; -import gobblin.broker.iface.SharedResourceFactoryResponse; -import gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.broker.iface.ScopeType; +import org.apache.gobblin.broker.iface.ScopedConfigView; +import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; public class TestFactoryWithRedirect<S extends ScopeType<S>> extends TestFactory<S> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestResourceKey.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestResourceKey.java b/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestResourceKey.java index 78b2609..1af7996 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestResourceKey.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/broker/TestResourceKey.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.broker; +package org.apache.gobblin.broker; -import gobblin.broker.iface.SharedResourceKey; +import org.apache.gobblin.broker.iface.SharedResourceKey; import lombok.Data; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactoryTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactoryTest.java index 280a47e..5e39f85 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactoryTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.cli; +package org.apache.gobblin.runtime.cli; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactoryTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactoryTest.java index be0b20f..b58f13d 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactoryTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.cli; +package org.apache.gobblin.runtime.cli; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroFlattenerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroFlattenerTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroFlattenerTest.java index 79db63c..521bda2 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroFlattenerTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroFlattenerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; import org.apache.avro.Schema; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroUtilsTest.java index 08a19f4..5114599 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/AvroUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/ClustersNamesTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/ClustersNamesTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/ClustersNamesTest.java index 2cbebd2..34ad41f 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/ClustersNamesTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/ClustersNamesTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/ConfigUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/ConfigUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/ConfigUtilsTest.java index de8a877..0339eaa 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/ConfigUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/ConfigUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.File; import java.io.IOException; @@ -40,8 +40,8 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; public class ConfigUtilsTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/DatePartitionTypeTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/DatePartitionTypeTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/DatePartitionTypeTest.java index a46d258..3ab8d3c 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/DatePartitionTypeTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/DatePartitionTypeTest.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 org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/ExecutorsUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/ExecutorsUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/ExecutorsUtilsTest.java index d578904..0d7bb07 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/ExecutorsUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/ExecutorsUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.util.Arrays; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/FileListUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/FileListUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/FileListUtilsTest.java index 9c926d5..547af08 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/FileListUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/FileListUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/ForkOperatorUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/ForkOperatorUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/ForkOperatorUtilsTest.java index 31cc0c7..5941749 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/ForkOperatorUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/ForkOperatorUtilsTest.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/HadoopUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/HadoopUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/HadoopUtilsTest.java index c9fb2d2..768dbdd 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/HadoopUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/HadoopUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; import java.net.URI; @@ -42,7 +42,7 @@ import com.google.common.base.Optional; import com.google.common.collect.Maps; import com.google.common.io.Files; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; @Test(groups = { "gobblin.util" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/HeapDumpForTaskUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/HeapDumpForTaskUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/HeapDumpForTaskUtilsTest.java index f85ddc9..ba91a75 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/HeapDumpForTaskUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/HeapDumpForTaskUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.BufferedReader; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/JobLauncherUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/JobLauncherUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/JobLauncherUtilsTest.java index 0bac925..c11fcc4 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/JobLauncherUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/JobLauncherUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; import java.util.Arrays; @@ -29,13 +29,13 @@ import org.slf4j.LoggerFactory; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -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.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-utility/src/test/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandlerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandlerTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandlerTest.java index e3b7e1b..20407a5 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandlerTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandlerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import org.mockito.Mockito; import org.slf4j.Logger; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/ParallelRunnerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/ParallelRunnerTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/ParallelRunnerTest.java index cd7a46e..d2cd06e 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/ParallelRunnerTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/ParallelRunnerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; @@ -50,11 +50,11 @@ import com.google.common.io.Closer; import com.google.gson.Gson; import com.google.gson.JsonElement; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.Watermark; -import gobblin.source.extractor.WatermarkSerializerHelper; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.io.SeekableFSInputStream; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.Watermark; +import org.apache.gobblin.source.extractor.WatermarkSerializerHelper; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.io.SeekableFSInputStream; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/PortUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/PortUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/PortUtilsTest.java index 1e15688..b1daf48 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/PortUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/PortUtilsTest.java @@ -10,7 +10,7 @@ * CONDITIONS OF ANY KIND, either express or implied. */ -package gobblin.util; +package org.apache.gobblin.util; import org.mockito.Mockito; import org.mockito.invocation.InvocationOnMock; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/PropertiesUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/PropertiesUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/PropertiesUtilsTest.java index 6d0082c..87f6828 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/PropertiesUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/PropertiesUtilsTest.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.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/PullFileLoaderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/PullFileLoaderTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/PullFileLoaderTest.java index f2612b3..ab1a72a 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/PullFileLoaderTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/PullFileLoaderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; import java.util.Collection; @@ -30,7 +30,7 @@ import org.testng.annotations.Test; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; public class PullFileLoaderTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/RatedControlledFileSystemTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/RatedControlledFileSystemTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/RatedControlledFileSystemTest.java index 1e1e791..4818b0a 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/RatedControlledFileSystemTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/RatedControlledFileSystemTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; import java.util.Random; @@ -32,8 +32,8 @@ import org.testng.annotations.Test; import com.codahale.metrics.Meter; import com.google.common.math.DoubleMath; -import gobblin.util.limiter.Limiter; -import gobblin.util.limiter.RateBasedLimiter; +import org.apache.gobblin.util.limiter.Limiter; +import org.apache.gobblin.util.limiter.RateBasedLimiter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/SerializationUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/SerializationUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/SerializationUtilsTest.java index 070bca2..fa32b42 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/SerializationUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/SerializationUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; @@ -27,7 +27,7 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/StringParsingUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/StringParsingUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/StringParsingUtilsTest.java index aeb945c..8ed3ab5 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/StringParsingUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/StringParsingUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/TestImmutableProperties.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/TestImmutableProperties.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/TestImmutableProperties.java index 92afae1..1592fee 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/TestImmutableProperties.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/TestImmutableProperties.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/TimeRangeCheckerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/TimeRangeCheckerTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/TimeRangeCheckerTest.java index 8abc62f..a2882f1 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/TimeRangeCheckerTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/TimeRangeCheckerTest.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.ConfigurationKeys; import org.joda.time.DateTime; import org.joda.time.DateTimeZone; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/WriterUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/WriterUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/WriterUtilsTest.java index b04bbd3..820b5a3 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/WriterUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/WriterUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import com.google.common.base.Optional; import org.apache.avro.file.CodecFactory; @@ -23,13 +23,13 @@ import org.apache.hadoop.fs.Path; 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.source.workunit.Extract; -import gobblin.source.workunit.WorkUnit; -import gobblin.source.workunit.Extract.TableType; +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.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.Extract.TableType; /** * Tests for {@link WriterUtils}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPackingTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPackingTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPackingTest.java index 022a3b7..749dc24 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPackingTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPackingTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.binpacking; +package org.apache.gobblin.util.binpacking; import java.util.List; @@ -24,10 +24,10 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; -import gobblin.source.workunit.WorkUnitWeighter; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.WorkUnitWeighter; public class WorstFitDecreasingBinPackingTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/callbacks/TestCallbacksDispatcher.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/callbacks/TestCallbacksDispatcher.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/callbacks/TestCallbacksDispatcher.java index 41f2b13..90099f9 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/callbacks/TestCallbacksDispatcher.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/callbacks/TestCallbacksDispatcher.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util.callbacks; +package org.apache.gobblin.util.callbacks; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executors; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskSchedulerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskSchedulerTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskSchedulerTest.java index 12a302b..1ef192b 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskSchedulerTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskSchedulerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.concurrent; +package org.apache.gobblin.util.concurrent; import com.google.common.base.Optional; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskSchedulerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskSchedulerTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskSchedulerTest.java index b81648f..f321f51 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskSchedulerTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskSchedulerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.concurrent; +package org.apache.gobblin.util.concurrent; import com.google.common.base.Optional; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactoryTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactoryTest.java index 1f6c2ba..26b4fff 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactoryTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.concurrent; +package org.apache.gobblin.util.concurrent; import org.apache.commons.lang.StringUtils; import org.hamcrest.Matchers; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerTest.java index 0ea1cee..04c457f 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/concurrent/TaskSchedulerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.concurrent; +package org.apache.gobblin.util.concurrent; import java.io.IOException; import java.util.concurrent.TimeUnit; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/dataset/DatasetUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/dataset/DatasetUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/dataset/DatasetUtilsTest.java index 250684f..9490869 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/dataset/DatasetUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/dataset/DatasetUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.dataset; +package org.apache.gobblin.util.dataset; import java.util.Map; @@ -24,8 +24,8 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/executors/IteratorExecutorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/executors/IteratorExecutorTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/executors/IteratorExecutorTest.java index adb2bd3..b1eb818 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/executors/IteratorExecutorTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/executors/IteratorExecutorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.executors; +package org.apache.gobblin.util.executors; import java.util.Iterator; import java.util.concurrent.Callable; @@ -37,7 +37,7 @@ import org.testng.annotations.Test; import com.google.common.base.Predicate; import com.google.common.util.concurrent.ThreadFactoryBuilder; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.testing.AssertWithBackoff; public class IteratorExecutorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/FileSystemFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/FileSystemFactoryTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/FileSystemFactoryTest.java index ab0416c..f0e37f4 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/FileSystemFactoryTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/FileSystemFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.filesystem; +package org.apache.gobblin.util.filesystem; import java.net.URI; import java.util.List; @@ -28,11 +28,11 @@ import org.testng.annotations.Test; import com.typesafe.config.ConfigFactory; -import gobblin.broker.SharedResourcesBrokerFactory; -import gobblin.broker.SharedResourcesBrokerImpl; -import gobblin.broker.SimpleScopeType; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.util.DecoratorUtils; +import org.apache.gobblin.broker.SharedResourcesBrokerFactory; +import org.apache.gobblin.broker.SharedResourcesBrokerImpl; +import org.apache.gobblin.broker.SimpleScopeType; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.util.DecoratorUtils; public class FileSystemFactoryTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystemTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystemTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystemTest.java index 7505331..db6d791 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystemTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystemTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.filesystem; +package org.apache.gobblin.util.filesystem; import java.io.File; import java.net.URI; @@ -29,7 +29,7 @@ import org.testng.annotations.Test; import com.google.common.io.Files; -import gobblin.util.DecoratorUtils; +import org.apache.gobblin.util.DecoratorUtils; public class InstrumentedLocalFileSystemTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/ThrottledFileSystemTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/ThrottledFileSystemTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/ThrottledFileSystemTest.java index 50f1af1..f8a863f 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/ThrottledFileSystemTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/filesystem/ThrottledFileSystemTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.filesystem; +package org.apache.gobblin.util.filesystem; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; @@ -26,9 +26,9 @@ import org.mockito.stubbing.Answer; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.util.limiter.CountBasedLimiter; -import gobblin.util.limiter.Limiter; -import gobblin.util.limiter.NotEnoughPermitsException; +import org.apache.gobblin.util.limiter.CountBasedLimiter; +import org.apache.gobblin.util.limiter.Limiter; +import org.apache.gobblin.util.limiter.NotEnoughPermitsException; public class ThrottledFileSystemTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/filters/RegexPathFilterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/filters/RegexPathFilterTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/filters/RegexPathFilterTest.java index ffab9a4..8f730f2 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/filters/RegexPathFilterTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/filters/RegexPathFilterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.filters; +package org.apache.gobblin.util.filters; import org.apache.hadoop.fs.Path; import org.testng.Assert; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/guid/GuidTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/guid/GuidTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/guid/GuidTest.java index 04aed92..94211c0 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/guid/GuidTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/guid/GuidTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.guid; +package org.apache.gobblin.util.guid; import java.io.IOException; import java.util.Random; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/io/GsonInterfaceAdapterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/GsonInterfaceAdapterTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/GsonInterfaceAdapterTest.java index 8e6ce80..17f1ac0 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/GsonInterfaceAdapterTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/GsonInterfaceAdapterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.io; +package org.apache.gobblin.util.io; import org.testng.Assert; import org.testng.annotations.Test; @@ -23,8 +23,8 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.gson.Gson; -import gobblin.util.test.BaseClass; -import gobblin.util.test.TestClass; +import org.apache.gobblin.util.test.BaseClass; +import org.apache.gobblin.util.test.TestClass; public class GsonInterfaceAdapterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredInputStreamTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredInputStreamTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredInputStreamTest.java index 19dfd22..fc9ce35 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredInputStreamTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredInputStreamTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.io; +package org.apache.gobblin.util.io; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredOutputStreamTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredOutputStreamTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredOutputStreamTest.java index f637732..0d33629 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredOutputStreamTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/MeteredOutputStreamTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.io; +package org.apache.gobblin.util.io; import java.io.ByteArrayOutputStream; import java.io.DataOutputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamCopierTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamCopierTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamCopierTest.java index a7a1fa2..afde7dd 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamCopierTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamCopierTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.io; +package org.apache.gobblin.util.io; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; @@ -27,7 +27,7 @@ import com.codahale.metrics.Meter; import com.codahale.metrics.MetricRegistry; import com.google.common.base.Charsets; -import gobblin.util.limiter.CountBasedLimiter; +import org.apache.gobblin.util.limiter.CountBasedLimiter; public class StreamCopierTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamUtilsTest.java index 368a4a2..003ea77 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/StreamUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.io; +package org.apache.gobblin.util.io; import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.Matchers.isIn; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/io/ThrottledInputStreamTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/ThrottledInputStreamTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/ThrottledInputStreamTest.java index c3f2c90..22a00ef 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/io/ThrottledInputStreamTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/io/ThrottledInputStreamTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.io; +package org.apache.gobblin.util.io; import java.io.ByteArrayInputStream; import java.io.InputStream; @@ -26,8 +26,8 @@ import org.testng.annotations.Test; import com.google.common.base.Charsets; -import gobblin.util.limiter.CountBasedLimiter; -import gobblin.util.limiter.Limiter; +import org.apache.gobblin.util.limiter.CountBasedLimiter; +import org.apache.gobblin.util.limiter.Limiter; public class ThrottledInputStreamTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/CountBasedLimiterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/CountBasedLimiterTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/CountBasedLimiterTest.java index 3c38328..e33af47 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/CountBasedLimiterTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/CountBasedLimiterTest.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.util.limiter; +package org.apache.gobblin.util.limiter; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.util.limiter.CountBasedLimiter; -import gobblin.util.limiter.Limiter; +import org.apache.gobblin.util.limiter.CountBasedLimiter; +import org.apache.gobblin.util.limiter.Limiter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/DefaultLimiterFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/DefaultLimiterFactoryTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/DefaultLimiterFactoryTest.java index 23d91c2..711b4be 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/DefaultLimiterFactoryTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/DefaultLimiterFactoryTest.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.util.limiter; +package org.apache.gobblin.util.limiter; import java.util.concurrent.TimeUnit; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/MultiLimiterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/MultiLimiterTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/MultiLimiterTest.java index 1bde6fc..eaacf52 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/MultiLimiterTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/MultiLimiterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.limiter; +package org.apache.gobblin.util.limiter; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/RateBasedLimiterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/RateBasedLimiterTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/RateBasedLimiterTest.java index 48c2faa..a925f61 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/RateBasedLimiterTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/RateBasedLimiterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.limiter; +package org.apache.gobblin.util.limiter; import java.util.Random; import java.util.concurrent.TimeUnit; @@ -28,8 +28,8 @@ import org.testng.annotations.Test; import com.codahale.metrics.Meter; import com.google.common.math.DoubleMath; -import gobblin.util.limiter.Limiter; -import gobblin.util.limiter.RateBasedLimiter; +import org.apache.gobblin.util.limiter.Limiter; +import org.apache.gobblin.util.limiter.RateBasedLimiter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/TimeBasedLimiterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/TimeBasedLimiterTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/TimeBasedLimiterTest.java index 5e76362..8197cc9 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/TimeBasedLimiterTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/TimeBasedLimiterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.limiter; +package org.apache.gobblin.util.limiter; import java.util.concurrent.TimeUnit; @@ -24,8 +24,8 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.util.limiter.Limiter; -import gobblin.util.limiter.TimeBasedLimiter; +import org.apache.gobblin.util.limiter.Limiter; +import org.apache.gobblin.util.limiter.TimeBasedLimiter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactoryTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactoryTest.java index 62b1583..9f4b23d 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactoryTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.limiter.broker; +package org.apache.gobblin.util.limiter.broker; import java.util.Map; @@ -27,18 +27,18 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.broker.BrokerConstants; -import gobblin.broker.SharedResourcesBrokerFactory; -import gobblin.broker.SharedResourcesBrokerImpl; -import gobblin.broker.SimpleScope; -import gobblin.broker.SimpleScopeType; -import gobblin.broker.iface.NotConfiguredException; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.util.limiter.CountBasedLimiter; -import gobblin.util.limiter.Limiter; -import gobblin.util.limiter.MultiLimiter; -import gobblin.util.limiter.NoopLimiter; -import gobblin.broker.ResourceInstance; +import org.apache.gobblin.broker.BrokerConstants; +import org.apache.gobblin.broker.SharedResourcesBrokerFactory; +import org.apache.gobblin.broker.SharedResourcesBrokerImpl; +import org.apache.gobblin.broker.SimpleScope; +import org.apache.gobblin.broker.SimpleScopeType; +import org.apache.gobblin.broker.iface.NotConfiguredException; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.util.limiter.CountBasedLimiter; +import org.apache.gobblin.util.limiter.Limiter; +import org.apache.gobblin.util.limiter.MultiLimiter; +import org.apache.gobblin.util.limiter.NoopLimiter; +import org.apache.gobblin.broker.ResourceInstance; public class SharedLimiterFactoryTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProviderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProviderTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProviderTest.java index e936e3b..d78fc79 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProviderTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProviderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.recordcount; +package org.apache.gobblin.util.recordcount; import java.util.regex.Pattern; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProviderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProviderTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProviderTest.java index a0bd169..9248b03 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProviderTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProviderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.recordcount; +package org.apache.gobblin.util.recordcount; import org.apache.hadoop.fs.Path; import org.testng.Assert; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/reflection/GobblinConstructorUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/reflection/GobblinConstructorUtilsTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/reflection/GobblinConstructorUtilsTest.java index d374004..564073f 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/reflection/GobblinConstructorUtilsTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/reflection/GobblinConstructorUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.reflection; +package org.apache.gobblin.util.reflection; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/BruteForceAllocatorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/BruteForceAllocatorTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/BruteForceAllocatorTest.java index 05c25dc..1243cd1 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/BruteForceAllocatorTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/BruteForceAllocatorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterableTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterableTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterableTest.java index 4002e56..58a56ea 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterableTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterableTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.util.Comparator; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/GreedyAllocatorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/GreedyAllocatorTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/GreedyAllocatorTest.java index 577b2ee..c1d52d6 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/GreedyAllocatorTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/GreedyAllocatorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocatorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocatorTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocatorTest.java index 8e749ad..dc7f170 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocatorTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocatorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.util.Comparator; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/PreOrderAllocatorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/PreOrderAllocatorTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/PreOrderAllocatorTest.java index 8e3e17d..38d5d99 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/PreOrderAllocatorTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/PreOrderAllocatorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ResourcePoolTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ResourcePoolTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ResourcePoolTest.java index b4f54fe..2b80591 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ResourcePoolTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/ResourcePoolTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequest.java index 3dbdca3..d935e4f 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.util.Comparator; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequestor.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequestor.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequestor.java index 56200c9..b3e621b 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequestor.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/StringRequestor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.io.IOException; import java.util.Collections; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/VectorAlgebraTest.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/VectorAlgebraTest.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/VectorAlgebraTest.java index 03c137a..872397d 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/VectorAlgebraTest.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/request_allocation/VectorAlgebraTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/test/BaseClass.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/test/BaseClass.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/test/BaseClass.java index b875829..bbb1c54 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/test/BaseClass.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/test/BaseClass.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/test/ExtendedClass.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/test/ExtendedClass.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/test/ExtendedClass.java index cad15d2..beec266 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/test/ExtendedClass.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/test/ExtendedClass.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestClass.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestClass.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestClass.java index ab3abf5..26d32b8 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestClass.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestClass.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestHelloWorldSource.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestHelloWorldSource.java b/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestHelloWorldSource.java index 820d41e..658e607 100644 --- a/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestHelloWorldSource.java +++ b/gobblin-utility/src/test/java/org/apache/gobblin/util/test/TestHelloWorldSource.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import java.io.IOException; import java.util.List; @@ -22,11 +22,11 @@ import java.util.List; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.DataRecordException; -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.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; /** * Unit tests for {@link HelloWorldSource} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinApplicationMaster.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinApplicationMaster.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinApplicationMaster.java index 1a56625..ea60c4e 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinApplicationMaster.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinApplicationMaster.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import java.util.Collections; import java.util.List; @@ -47,12 +47,12 @@ import com.google.common.base.Optional; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.annotation.Alpha; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinClusterManager; -import gobblin.util.JvmUtils; -import gobblin.util.logs.Log4jConfigurationHelper; -import gobblin.yarn.event.DelegationTokenUpdatedEvent; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinClusterManager; +import org.apache.gobblin.util.JvmUtils; +import org.apache.gobblin.util.logs.Log4jConfigurationHelper; +import org.apache.gobblin.yarn.event.DelegationTokenUpdatedEvent; /**
