You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:52:20 UTC
[02/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-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;
/**