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;
