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:22 UTC
[04/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-tunnel/src/test/java/org/apache/gobblin/tunnel/ConnectProxyServer.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/ConnectProxyServer.java b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/ConnectProxyServer.java
index 14d40bd..9b3d1da 100644
--- a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/ConnectProxyServer.java
+++ b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/ConnectProxyServer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
import org.apache.commons.io.IOUtils;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/DoubleEchoServer.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/DoubleEchoServer.java b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/DoubleEchoServer.java
index ab76bb6..719fd1e 100644
--- a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/DoubleEchoServer.java
+++ b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/DoubleEchoServer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
import java.io.BufferedReader;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/EasyThread.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/EasyThread.java b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/EasyThread.java
index 5e8b311..7d0531b 100644
--- a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/EasyThread.java
+++ b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/EasyThread.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
import java.util.Collections;
import java.util.HashSet;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/MockServer.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/MockServer.java b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/MockServer.java
index f4439a9..70490e9 100644
--- a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/MockServer.java
+++ b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/MockServer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
import org.apache.commons.io.IOUtils;
import org.slf4j.Logger;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkFirstDoubleEchoServer.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkFirstDoubleEchoServer.java b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkFirstDoubleEchoServer.java
index f38840e..cef2848 100644
--- a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkFirstDoubleEchoServer.java
+++ b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkFirstDoubleEchoServer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
import java.io.BufferedReader;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkPastServer.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkPastServer.java b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkPastServer.java
index c18787a..f8a0a66 100644
--- a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkPastServer.java
+++ b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TalkPastServer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
import org.apache.commons.lang.StringUtils;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TestTunnelWithArbitraryTCPTraffic.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TestTunnelWithArbitraryTCPTraffic.java b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TestTunnelWithArbitraryTCPTraffic.java
index 2fa7410..1f701fc 100644
--- a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TestTunnelWithArbitraryTCPTraffic.java
+++ b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TestTunnelWithArbitraryTCPTraffic.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
import static org.testng.Assert.assertEquals;
import static org.testng.Assert.assertFalse;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TunnelTest.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TunnelTest.java b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TunnelTest.java
index 5d2d4c7..6fa2254 100644
--- a/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TunnelTest.java
+++ b/gobblin-tunnel/src/test/java/org/apache/gobblin/tunnel/TunnelTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
import java.io.File;
import java.io.FileOutputStream;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java
index 70f2806..6deb3dd 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
import com.google.common.base.Joiner;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
import javax.annotation.Nonnull;
import lombok.Builder;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/DefaultBrokerCache.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/DefaultBrokerCache.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/DefaultBrokerCache.java
index c9cacd4..6425bab 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/DefaultBrokerCache.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/DefaultBrokerCache.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
import java.io.Closeable;
import java.io.IOException;
@@ -35,10 +35,10 @@ import com.google.common.collect.Maps;
import com.google.common.util.concurrent.Service;
import com.google.common.util.concurrent.Striped;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceKey;
-import gobblin.broker.iface.NoSuchScopeException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.NoSuchScopeException;
import javax.annotation.Nonnull;
import lombok.AllArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/EmptyKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/EmptyKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/EmptyKey.java
index 61c785c..edaa3a4 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/EmptyKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/EmptyKey.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.EqualsAndHashCode;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/KeyedScopedConfigViewImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/KeyedScopedConfigViewImpl.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/KeyedScopedConfigViewImpl.java
index 38205b4..1c830c2 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/KeyedScopedConfigViewImpl.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/KeyedScopedConfigViewImpl.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
import com.google.common.base.Joiner;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceKey;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.util.ConfigUtils;
import javax.annotation.Nullable;
import lombok.Data;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/NonExtendableBrokerView.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/NonExtendableBrokerView.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/NonExtendableBrokerView.java
index 5a77ec7..c8c9384 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/NonExtendableBrokerView.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/NonExtendableBrokerView.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
import java.util.List;
import java.util.Map;
-import gobblin.broker.iface.ScopeInstance;
-import gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopeInstance;
+import org.apache.gobblin.broker.iface.ScopeType;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/ResourceInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/ResourceInstance.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/ResourceInstance.java
index 5df9da0..e0f8611 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/ResourceInstance.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/ResourceInstance.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 lombok.Data;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/ScopeWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/ScopeWrapper.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/ScopeWrapper.java
index 68780fc..64aa96c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/ScopeWrapper.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/ScopeWrapper.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
-import gobblin.broker.iface.ScopeInstance;
+import org.apache.gobblin.broker.iface.ScopeInstance;
import java.util.Collection;
-import gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopeType;
import lombok.Data;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java
index 66a192e..3b8726d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
import java.util.Map;
@@ -27,10 +27,10 @@ import com.google.common.collect.Maps;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.iface.ScopeInstance;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.broker.iface.ScopeInstance;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.ConfigUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java
index 6428cb7..2287922 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
import java.io.IOException;
import java.util.LinkedList;
@@ -32,14 +32,14 @@ import com.google.common.collect.Maps;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.iface.NoSuchScopeException;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeInstance;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceKey;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.broker.iface.NoSuchScopeException;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeInstance;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.ConfigUtils;
import javax.annotation.Nullable;
import javax.annotation.concurrent.NotThreadSafe;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java
index 304c519..d8414da 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
import java.io.Closeable;
import java.io.IOException;
@@ -27,7 +27,7 @@ import org.slf4j.Logger;
import com.google.common.util.concurrent.Service;
-import gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopeType;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/TTLResourceEntry.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/TTLResourceEntry.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/TTLResourceEntry.java
index 67d2385..e92b542 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/TTLResourceEntry.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/TTLResourceEntry.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
import edu.umd.cs.findbugs.annotations.SuppressWarnings;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java
index 070a385..64e49de 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java
@@ -43,4 +43,4 @@
* and keys (for example, the location of the log file could be settable through configuration, and user can specify
* a different location for global and task scope logs).
*/
-package gobblin.broker;
+package org.apache.gobblin.broker;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklist.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklist.java b/gobblin-utility/src/main/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklist.java
index 597d8eb..346110c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklist.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/data/management/copy/hive/WhitelistBlacklist.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.data.management.copy.hive;
+package org.apache.gobblin.data.management.copy.hive;
import java.io.IOException;
import java.io.Serializable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliApplication.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliApplication.java b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliApplication.java
index ab3d098..e16ece7 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliApplication.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliApplication.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
/**
* An application that can be called by {@link GobblinCli}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectFactory.java
index 3baab78..cce81a0 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectFactory.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/main/java/org/apache/gobblin/runtime/cli/CliObjectOption.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectOption.java b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectOption.java
index a04a2ba..f57c7b2 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectOption.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectOption.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectSupport.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectSupport.java b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectSupport.java
index edd2dac..33baa8e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectSupport.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/CliObjectSupport.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactory.java
index f9f6a1a..e219036 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import java.io.IOException;
import java.lang.reflect.Constructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/GobblinCli.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/GobblinCli.java b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/GobblinCli.java
index 412efd1..e1e1a5c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/GobblinCli.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/GobblinCli.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import com.google.common.collect.Sets;
-import gobblin.annotation.Alias;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.util.ClassAliasResolver;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/NotOnCli.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/NotOnCli.java b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/NotOnCli.java
index 9649729..c3aed92 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/NotOnCli.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/NotOnCli.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactory.java
index b94e281..4acaf3f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ApplicationLauncherUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ApplicationLauncherUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ApplicationLauncherUtils.java
index 514fb98..e6e36c9 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ApplicationLauncherUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ApplicationLauncherUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
/**
* A utility class for the application launcher.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoCloseableLock.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoCloseableLock.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoCloseableLock.java
index 6cb7c0a..6703a4a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoCloseableLock.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoCloseableLock.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.concurrent.locks.Lock;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoReturnableObject.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoReturnableObject.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoReturnableObject.java
index c5b6c0b..55de9f8 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoReturnableObject.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/AutoReturnableObject.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.Closeable;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java
index 9b8b025..414c140 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.ArrayList;
import java.util.Arrays;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java
index f126272..694a40b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java
index cb30941..fc9522a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.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.Map;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/CLIPasswordEncryptor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/CLIPasswordEncryptor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/CLIPasswordEncryptor.java
index b82572a..57ef86f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/CLIPasswordEncryptor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/CLIPasswordEncryptor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -34,7 +34,7 @@ import org.jasypt.util.text.TextEncryptor;
import com.google.common.base.Optional;
-import gobblin.password.PasswordManager;
+import org.apache.gobblin.password.PasswordManager;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ClusterNameTags.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ClusterNameTags.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ClusterNameTags.java
index 5f0b585..c16662f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ClusterNameTags.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ClusterNameTags.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ClustersNames.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ClustersNames.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ClustersNames.java
index 7c60407..5819236 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ClustersNames.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ClustersNames.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.IOException;
import java.io.InputStream;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ConfigUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ConfigUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ConfigUtils.java
index aedcf07..96b219d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ConfigUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ConfigUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.IOException;
import java.io.StringReader;
@@ -45,8 +45,8 @@ import com.typesafe.config.ConfigFactory;
import com.typesafe.config.ConfigList;
import com.typesafe.config.ConfigValue;
-import gobblin.configuration.State;
-import gobblin.password.PasswordManager;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.password.PasswordManager;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/DatasetFilterUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/DatasetFilterUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/DatasetFilterUtils.java
index 4e89953..6eed809 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/DatasetFilterUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/DatasetFilterUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.List;
import java.util.Set;
@@ -26,7 +26,7 @@ import org.apache.commons.lang3.StringUtils;
import com.google.common.collect.Lists;
import com.google.common.collect.Sets;
-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/main/java/org/apache/gobblin/util/DatePartitionType.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java
index be8be66..f48bce1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java
@@ -10,7 +10,7 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.LinkedHashMap;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/Either.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/Either.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/Either.java
index 0891c58..b75b3a7 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/Either.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/Either.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import lombok.AccessLevel;
import lombok.AllArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/EmailUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/EmailUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/EmailUtils.java
index 80562c8..3d8edcf 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/EmailUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/EmailUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.net.InetAddress;
import java.net.UnknownHostException;
@@ -28,9 +28,9 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Splitter;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.password.PasswordManager;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.password.PasswordManager;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/EmptyIterable.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/EmptyIterable.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/EmptyIterable.java
index 2acb98f..3e78afb 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/EmptyIterable.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/EmptyIterable.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ExecutorsUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ExecutorsUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ExecutorsUtils.java
index 7cbba01..b05674a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ExecutorsUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ExecutorsUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.List;
import java.util.concurrent.Callable;
@@ -29,9 +29,9 @@ import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import com.google.common.util.concurrent.ListeningScheduledExecutorService;
-import gobblin.util.executors.MDCPropagatingCallable;
-import gobblin.util.executors.MDCPropagatingRunnable;
-import gobblin.util.executors.MDCPropagatingScheduledExecutorService;
+import org.apache.gobblin.util.executors.MDCPropagatingCallable;
+import org.apache.gobblin.util.executors.MDCPropagatingRunnable;
+import org.apache.gobblin.util.executors.MDCPropagatingScheduledExecutorService;
import org.slf4j.Logger;
import com.google.common.base.Function;
@@ -41,7 +41,7 @@ import com.google.common.collect.Lists;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
-import gobblin.util.executors.MDCPropagatingExecutorService;
+import org.apache.gobblin.util.executors.MDCPropagatingExecutorService;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ExponentialBackoff.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ExponentialBackoff.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ExponentialBackoff.java
index 9a36e1f..0e0c51c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ExponentialBackoff.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ExponentialBackoff.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/FileListUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/FileListUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/FileListUtils.java
index 3bd3f25..9472db6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/FileListUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/FileListUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.FileNotFoundException;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java
index 4a39f85..ce7df72 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import org.apache.hadoop.fs.Path;
import com.google.common.base.Preconditions;
import com.google.common.base.Strings;
-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/main/java/org/apache/gobblin/util/HadoopUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java
index 1e9897f..1b9b45f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.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;
@@ -63,11 +63,11 @@ import com.typesafe.config.ConfigValue;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.deprecation.DeprecationUtils;
-import gobblin.util.executors.ScalingThreadPoolExecutor;
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.deprecation.DeprecationUtils;
+import org.apache.gobblin.util.executors.ScalingThreadPoolExecutor;
+import org.apache.gobblin.writer.DataWriter;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/HeapDumpForTaskUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/HeapDumpForTaskUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/HeapDumpForTaskUtils.java
index 57d32bd..9bc7f39 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/HeapDumpForTaskUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/HeapDumpForTaskUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.BufferedWriter;
import java.io.IOException;
@@ -26,7 +26,7 @@ import org.apache.hadoop.fs.Path;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/HiveJdbcConnector.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/HiveJdbcConnector.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/HiveJdbcConnector.java
index 92c6cca..d301e29 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/HiveJdbcConnector.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/HiveJdbcConnector.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.Closeable;
import java.io.File;
@@ -36,7 +36,7 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Preconditions;
-import gobblin.password.PasswordManager;
+import org.apache.gobblin.password.PasswordManager;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/HostUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/HostUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/HostUtils.java
index 4bb27e4..c847817 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/HostUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/HostUtils.java
@@ -1,4 +1,4 @@
-package gobblin.util;
+package org.apache.gobblin.util;
import java.net.InetAddress;
import java.net.UnknownHostException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/Id.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/Id.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/Id.java
index 11a6cb7..b6e4da1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/Id.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/Id.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import com.google.common.base.Joiner;
import com.google.common.base.Preconditions;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ImmutableProperties.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ImmutableProperties.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ImmutableProperties.java
index e6a79c7..0d4298d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ImmutableProperties.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ImmutableProperties.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.Collections;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/JobConfigurationUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/JobConfigurationUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/JobConfigurationUtils.java
index 95c04f5..957444c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/JobConfigurationUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/JobConfigurationUtils.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;
@@ -31,7 +31,7 @@ import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
-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/main/java/org/apache/gobblin/util/JobLauncherUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java
index 5444dc3..8bcb71f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.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;
@@ -39,10 +39,10 @@ import com.google.common.cache.CacheBuilder;
import com.google.common.collect.Lists;
import com.google.common.io.Closer;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+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/main/java/org/apache/gobblin/util/JvmUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/JvmUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/JvmUtils.java
index 9940964..c1f2b79 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/JvmUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/JvmUtils.java
@@ -1,4 +1,4 @@
-package gobblin.util;
+package org.apache.gobblin.util;
import com.google.common.base.Joiner;
import com.google.common.base.Optional;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandler.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandler.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandler.java
index dc64960..be6118d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandler.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandler.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/NoopCloseable.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/NoopCloseable.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/NoopCloseable.java
index 7c2d360..2864263 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/NoopCloseable.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/NoopCloseable.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.Closeable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ParallelRunner.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ParallelRunner.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ParallelRunner.java
index 211c565..c112d5b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ParallelRunner.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ParallelRunner.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import lombok.Data;
@@ -43,7 +43,7 @@ import com.google.common.base.Optional;
import com.google.common.collect.Lists;
import com.google.common.util.concurrent.Striped;
-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/main/java/org/apache/gobblin/util/PathUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/PathUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/PathUtils.java
index 3779f36..88ab113 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/PathUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/PathUtils.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;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/PortUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/PortUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/PortUtils.java
index 3a5c32f..76c0b5f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/PortUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/PortUtils.java
@@ -10,7 +10,7 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/PropertiesUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/PropertiesUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/PropertiesUtils.java
index 1da6c11..ac7abcf 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/PropertiesUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/PropertiesUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.Map;
import java.util.Properties;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemCache.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemCache.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemCache.java
index d658de0..0f4e94a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemCache.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemCache.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;
@@ -37,8 +37,8 @@ import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.security.token.Token;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java
index 1ab3423..e8f9fcc 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.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;
@@ -38,8 +38,8 @@ import org.apache.hadoop.io.Text;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.hadoop.security.token.Token;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java
index 341f148..d3bd8e3 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.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;
@@ -37,8 +37,8 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.io.Closer;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/PublisherUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/PublisherUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/PublisherUtils.java
index 33da24c..112f57a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/PublisherUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/PublisherUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.Collection;
import java.util.Map;
@@ -28,10 +28,10 @@ import com.google.common.collect.ArrayListMultimap;
import com.google.common.collect.Iterables;
import com.google.common.collect.Multimap;
-import gobblin.configuration.WorkUnitState;
-import gobblin.configuration.WorkUnitState.WorkingState;
-import gobblin.publisher.DataPublisher;
-import gobblin.source.workunit.Extract;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState.WorkingState;
+import org.apache.gobblin.publisher.DataPublisher;
+import org.apache.gobblin.source.workunit.Extract;
/**
* Utility class for {@link DataPublisher}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java
index fbfaa81..45884c9 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.IOException;
import java.io.InputStream;
@@ -47,7 +47,7 @@ import com.typesafe.config.ConfigFactory;
import com.typesafe.config.ConfigParseOptions;
import com.typesafe.config.ConfigSyntax;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java
index c3276aa..3146591 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.List;
import java.util.concurrent.Callable;
@@ -27,9 +27,9 @@ import com.google.common.base.Optional;
import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
-import gobblin.util.filesystem.ThrottledFileSystem;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.RateBasedLimiter;
+import org.apache.gobblin.util.filesystem.ThrottledFileSystem;
+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/main/java/org/apache/gobblin/util/SerializationUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/SerializationUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/SerializationUtils.java
index 6e6ed99..63d442d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/SerializationUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/SerializationUtils.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;
@@ -32,7 +32,7 @@ import org.apache.hadoop.fs.Path;
import com.google.common.io.BaseEncoding;
-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/main/java/org/apache/gobblin/util/StringParsingUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/StringParsingUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/StringParsingUtils.java
index 67ae2bb..1c7cfb1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/StringParsingUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/StringParsingUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/TemplateUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/TemplateUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/TemplateUtils.java
index 06a7785..c882701 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/TemplateUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/TemplateUtils.java
@@ -14,11 +14,11 @@
* 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;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
public class TemplateUtils {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/TimeRangeChecker.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/TimeRangeChecker.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/TimeRangeChecker.java
index f9a72e6..6d2bc2b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/TimeRangeChecker.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/TimeRangeChecker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.List;
import java.util.Map;
@@ -24,7 +24,7 @@ import com.google.common.base.Predicate;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Iterables;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
import lombok.AllArgsConstructor;
import org.joda.time.DateTime;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/WritableShimSerialization.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/WritableShimSerialization.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/WritableShimSerialization.java
index 3ba8fa2..50e5988 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/WritableShimSerialization.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/WritableShimSerialization.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.io.DataInputStream;
import java.io.DataOutputStream;
@@ -27,7 +27,7 @@ import org.apache.hadoop.io.serializer.Deserializer;
import org.apache.hadoop.io.serializer.Serialization;
import org.apache.hadoop.io.serializer.Serializer;
-import gobblin.compat.hadoop.WritableShim;
+import org.apache.gobblin.compat.hadoop.WritableShim;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/WriterUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/WriterUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/WriterUtils.java
index ec829e8..803b0ba 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/WriterUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/WriterUtils.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;
@@ -35,10 +35,10 @@ import com.google.common.base.Strings;
import lombok.extern.slf4j.Slf4j;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.workunit.WorkUnit;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/FieldWeighter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/FieldWeighter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/FieldWeighter.java
index 2d4b141..df92daa 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/FieldWeighter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/FieldWeighter.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.util.binpacking;
+package org.apache.gobblin.util.binpacking;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.source.workunit.WorkUnitWeighter;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnitWeighter;
import lombok.AllArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPacking.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPacking.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPacking.java
index 17ba13b..7af4f8f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPacking.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/binpacking/WorstFitDecreasingBinPacking.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.binpacking;
+package org.apache.gobblin.util.binpacking;
import java.io.Serializable;
import java.util.Collections;
@@ -31,10 +31,10 @@ import com.google.common.collect.Iterables;
import com.google.common.collect.Lists;
import com.google.common.collect.MinMaxPriorityQueue;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.source.workunit.WorkUnitBinPacker;
-import gobblin.source.workunit.WorkUnitWeighter;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnitBinPacker;
+import org.apache.gobblin.source.workunit.WorkUnitWeighter;
import javax.annotation.Nullable;
import javax.annotation.OverridingMethodsMustInvokeSuper;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/Callback.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/Callback.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/Callback.java
index f2250b3..61cb130 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/Callback.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/Callback.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 com.google.common.base.Function;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbackResult.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbackResult.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbackResult.java
index bdbd1bb..0132a82 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbackResult.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbackResult.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.Future;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbacksDispatcher.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbacksDispatcher.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbacksDispatcher.java
index 5f660ac..a4f3562 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbacksDispatcher.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbacksDispatcher.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.io.Closeable;
import java.io.IOException;
@@ -36,7 +36,7 @@ import com.google.common.base.Function;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.ExecutorsUtils;
import lombok.AllArgsConstructor;
import lombok.Data;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/package-info.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/package-info.java
index 41ca37f..759ae5d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/package-info.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/package-info.java
@@ -60,4 +60,4 @@
*
* </dl>
*/
-package gobblin.util.callbacks;
+package org.apache.gobblin.util.callbacks;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/AutoResetEvent.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/AutoResetEvent.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/AutoResetEvent.java
index ab2017b..94055a3 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/AutoResetEvent.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/AutoResetEvent.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.concurrent;
+package org.apache.gobblin.util.concurrent;
import java.util.concurrent.TimeUnit;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/CancellableTask.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/CancellableTask.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/CancellableTask.java
index f168953..1c9b79e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/CancellableTask.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/CancellableTask.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.concurrent;
+package org.apache.gobblin.util.concurrent;
import lombok.AllArgsConstructor;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskScheduler.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskScheduler.java
index 84ce614..c80195d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskScheduler.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/HashedWheelTimerTaskScheduler.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.Map;
@@ -31,7 +31,7 @@ import org.slf4j.MDC;
import com.google.common.base.Optional;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.ExecutorsUtils;
import lombok.Synchronized;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskScheduler.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskScheduler.java
index d655b03..1a24db8 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskScheduler.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledExecutorServiceTaskScheduler.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.Executors;
@@ -28,7 +28,7 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Optional;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.ExecutorsUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledTask.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledTask.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledTask.java
index c622319..6372dfe 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledTask.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/ScheduledTask.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.concurrent;
+package org.apache.gobblin.util.concurrent;
/**
* A task which can be scheduled to run recurrently by an instance of {@link TaskScheduler}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskScheduler.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskScheduler.java
index d626cdc..b9d4944 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskScheduler.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskScheduler.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.concurrent;
+package org.apache.gobblin.util.concurrent;
import java.io.Closeable;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactory.java
index 67e269f..e670d80 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerFactory.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/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerType.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerType.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerType.java
index c5dd53e..ce81b12 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerType.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/concurrent/TaskSchedulerType.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;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/dataset/DatasetUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/dataset/DatasetUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/dataset/DatasetUtils.java
index b8dc900..5d96915 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/dataset/DatasetUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/dataset/DatasetUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.dataset;
+package org.apache.gobblin.util.dataset;
import java.util.Map;
import java.util.regex.Pattern;
@@ -31,9 +31,9 @@ import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
-import gobblin.configuration.State;
-import gobblin.configuration.StateUtils;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.StateUtils;
+import org.apache.gobblin.source.workunit.WorkUnit;
public class DatasetUtils {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/deprecation/DeprecationUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/deprecation/DeprecationUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/deprecation/DeprecationUtils.java
index 94a7420..aeecece 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/deprecation/DeprecationUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/deprecation/DeprecationUtils.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.util.deprecation;
+package org.apache.gobblin.util.deprecation;
import java.util.List;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ForceQueuePolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ForceQueuePolicy.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ForceQueuePolicy.java
index 841ef69..787f309 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ForceQueuePolicy.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ForceQueuePolicy.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.RejectedExecutionHandler;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/IteratorExecutor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/IteratorExecutor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/IteratorExecutor.java
index e087d3c..13dc93e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/IteratorExecutor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/IteratorExecutor.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.List;
@@ -37,8 +37,8 @@ import com.google.common.collect.Iterables;
import com.google.common.collect.Lists;
import com.google.common.util.concurrent.Futures;
-import gobblin.util.Either;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.Either;
+import org.apache.gobblin.util.ExecutorsUtils;
import javax.annotation.Nullable;
import lombok.extern.slf4j.Slf4j;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingCallable.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingCallable.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingCallable.java
index 50837c8..b7a0fd4 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingCallable.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingCallable.java
@@ -10,7 +10,7 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
import org.slf4j.MDC;