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:21 UTC
[03/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java
index 7337ce0..8026827 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java
@@ -10,7 +10,7 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
import com.google.common.util.concurrent.ForwardingListeningExecutorService;
import com.google.common.util.concurrent.ListenableFuture;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java
index 21b919f..a21e668 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.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;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java
index 7a99fcf..b338b89 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java
@@ -10,7 +10,7 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
import com.google.common.base.Throwables;
import com.google.common.util.concurrent.AbstractFuture;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java
index d896e93..7dc36c4 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java
index a8ab17a..608dd41 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.Executors;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java
index b2317d3..4989275 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import org.apache.hadoop.fs.Path;
-import gobblin.util.Decorator;
+import org.apache.gobblin.util.Decorator;
import lombok.AllArgsConstructor;
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/filesystem/FileStatusEntry.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java
index 88b669a..24d11cf 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import com.google.common.base.Optional;
import java.io.FileNotFoundException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java
index c4a146f..d8b07b6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import java.io.IOException;
import java.net.URI;
@@ -42,9 +42,9 @@ import org.apache.hadoop.security.Credentials;
import org.apache.hadoop.security.token.Token;
import org.apache.hadoop.util.Progressable;
-import gobblin.util.Decorator;
+import org.apache.gobblin.util.Decorator;
-import static gobblin.util.filesystem.InstrumentedFileSystemUtils.*;
+import static org.apache.gobblin.util.filesystem.InstrumentedFileSystemUtils.*;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java
index 448ea99..3dac2d6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import java.io.IOException;
import java.net.URI;
@@ -24,14 +24,14 @@ import java.util.ServiceLoader;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
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/filesystem/FileSystemInstrumentation.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java
index 41ac1d0..24a4a74 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
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/filesystem/FileSystemInstrumentationFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java
index fb3ed4d..de2260c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import org.apache.hadoop.fs.FileSystem;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java
index ed20557..b3a929f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import java.net.URI;
import java.net.URISyntaxException;
@@ -25,7 +25,7 @@ import org.apache.hadoop.fs.FileSystem;
import com.google.common.base.Strings;
-import gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java
index 58fa913..601cbb3 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import java.net.URI;
-import gobblin.util.ClustersNames;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.util.ClustersNames;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java
index ec09ad1..da26b11 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import java.io.IOException;
import java.net.URI;
@@ -23,9 +23,9 @@ import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
-import gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
-import static gobblin.util.filesystem.InstrumentedFileSystemUtils.*;
+import static org.apache.gobblin.util.filesystem.InstrumentedFileSystemUtils.*;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java
index d73dc47..054012f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
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/filesystem/InstrumentedHDFSFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java
index 60cb30f..1c6e608 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import org.apache.hadoop.hdfs.DistributedFileSystem;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java
index 48b5138..783558f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import org.apache.hadoop.fs.LocalFileSystem;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java
index 47b227f..d5dc46a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java
index 697f518..fa4d940 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import org.apache.commons.io.monitor.FileAlterationListener;
import org.apache.hadoop.fs.Path;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java
index 4bac7ad..cf5891a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import org.apache.hadoop.fs.Path;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java
index 37a2ec8..1131b87 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import java.io.IOException;
import java.util.ArrayList;
@@ -32,7 +32,7 @@ import org.apache.hadoop.fs.PathFilter;
import com.google.common.collect.Maps;
-import gobblin.util.DecoratorUtils;
+import org.apache.gobblin.util.DecoratorUtils;
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/filesystem/PathAlterationObserverScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java
index 01f68b2..7321a0a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import java.io.IOException;
import java.util.List;
@@ -31,7 +31,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/filesystem/ThrottledFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java
index b1e4d14..491de82 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
import java.io.Closeable;
import java.io.IOException;
@@ -30,14 +30,14 @@ import org.apache.hadoop.fs.PathFilter;
import org.apache.hadoop.fs.permission.FsPermission;
import org.apache.hadoop.util.Progressable;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.HadoopUtils;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.NotEnoughPermitsException;
-import gobblin.util.limiter.broker.SharedLimiterFactory;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.NotEnoughPermitsException;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterFactory;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java
index 351e5f7..936453d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filters;
+package org.apache.gobblin.util.filters;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.PathFilter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java
index 6469442..2f7d075 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filters;
+package org.apache.gobblin.util.filters;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.PathFilter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java
index c634271..619d8d5 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filters;
+package org.apache.gobblin.util.filters;
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/filters/TarGpgPathFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java
index 5f881b2..7a6da2e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.filters;
+package org.apache.gobblin.util.filters;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.PathFilter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java
index 0e54356..6a07856 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.guid;
+package org.apache.gobblin.util.guid;
import lombok.EqualsAndHashCode;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java
index 3823700..a2f0946 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.guid;
+package org.apache.gobblin.util.guid;
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/hadoop/TokenUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java
index 33fc107..15d7cd1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.hadoop;
+package org.apache.gobblin.util.hadoop;
import java.io.DataOutputStream;
import java.io.File;
@@ -52,7 +52,7 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.base.Strings;
-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/http/HttpLimiterKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java
index 850c859..afc20fc 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.util.http;
+package org.apache.gobblin.util.http;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java
index 1adaef3..318a720 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
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/io/BatchedMeterDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java
index 9dccf8f..ecaa332 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import com.codahale.metrics.Meter;
-import gobblin.util.Decorator;
+import org.apache.gobblin.util.Decorator;
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/util/io/CloseableHttpConn.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java
index cb89d4a..f084ad0 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
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/io/FilterStreamUnpacker.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java
index afaf6d7..fb7b450 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import java.io.FilterInputStream;
import java.io.FilterOutputStream;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java
index 286709b..5973aa9 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import lombok.AllArgsConstructor;
import lombok.RequiredArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java
index c7d8d08..33d7cac 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import java.io.FilterInputStream;
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/io/MeteredOutputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java
index badcfc5..6144ebf 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import java.io.FilterOutputStream;
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/io/MeteredStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java
index 9282ec4..71bd6f7 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import com.codahale.metrics.Meter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java
index 24e7b25..6d07da1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
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/io/StreamCopier.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java
index 4c4d77d..48917bb 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import java.io.Closeable;
import java.io.IOException;
@@ -28,7 +28,7 @@ import java.nio.channels.WritableByteChannel;
import com.codahale.metrics.Meter;
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
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/util/io/StreamCopierSharedLimiterKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java
index 7a305d5..e7cbc00 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import java.net.URI;
@@ -23,8 +23,8 @@ import org.apache.hadoop.fs.LocalFileSystem;
import com.google.common.base.Joiner;
-import gobblin.util.ClustersNames;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.util.ClustersNames;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java
index 7995069..86f3a96 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import java.io.InputStream;
import java.net.URI;
@@ -23,19 +23,19 @@ import java.net.URI;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import gobblin.broker.EmptyKey;
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.MultiLimiter;
-import gobblin.util.limiter.NoopLimiter;
-import gobblin.util.limiter.broker.SharedLimiterFactory;
+import org.apache.gobblin.broker.EmptyKey;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.MultiLimiter;
+import org.apache.gobblin.util.limiter.NoopLimiter;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterFactory;
import lombok.AllArgsConstructor;
import lombok.Builder;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java
index 8e7b3db..428b209 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import java.io.IOException;
import java.io.InputStream;
@@ -43,7 +43,7 @@ import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.PositionedReadable;
import org.apache.hadoop.fs.Seekable;
-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/io/ThrottledInputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java
index 7c86e01..fd2edb0 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
import java.io.Closeable;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
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/util/iterators/InterruptibleIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java
index 8695d55..b1054f8 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.iterators;
+package org.apache.gobblin.util.iterators;
import java.util.Iterator;
import java.util.NoSuchElementException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java
index 168671d..83cafff 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.util.jdbc;
+package org.apache.gobblin.util.jdbc;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
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/jdbc/DataSourceModule.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java
index bd3fb61..84852f8 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.jdbc;
+package org.apache.gobblin.util.jdbc;
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/jdbc/DataSourceProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java
index 686fe91..1d67136 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.jdbc;
+package org.apache.gobblin.util.jdbc;
import java.util.Properties;
@@ -27,7 +27,7 @@ import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.name.Named;
-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/json/JsonUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java
index 62739e0..d575ce6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.util.json;
+package org.apache.gobblin.util.json;
import org.codehaus.jackson.JsonFactory;
import org.codehaus.jackson.map.ObjectMapper;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java
index ad2a4af..1a4905d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
/**
* An enumeration of types of {@link Limiter}s supported out-of-the-box.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java
index 8d56da4..081bb17 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.io.Closeable;
import com.google.common.annotations.VisibleForTesting;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
import lombok.AccessLevel;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java
index c374097..c9aa104 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.util.concurrent.TimeUnit;
import com.google.common.base.Preconditions;
-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/limiter/Limiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java
index 4e805b7..44b2ff9 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
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/limiter/LimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java
index eef4800..b17381b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import com.typesafe.config.Config;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java
index f00f723..5c88ca6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
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/limiter/NonRefillableLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java
index 3975599..5567fee 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
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/limiter/NoopLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java
index 258d4c0..4eed19b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
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/limiter/NotEnoughPermitsException.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java
index 6e9d84e..6bedd87 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.io.IOException;
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java
index 5ae7243..6813114 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.io.Closeable;
import java.io.IOException;
@@ -24,7 +24,7 @@ import java.util.concurrent.Semaphore;
import com.google.common.primitives.Ints;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
index a18384c..05f3bc5 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.io.Closeable;
import java.util.concurrent.TimeUnit;
@@ -24,7 +24,7 @@ import com.google.common.primitives.Ints;
import com.google.common.util.concurrent.RateLimiter;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java
index b7904df..8523528 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
import java.io.Closeable;
import java.util.concurrent.ScheduledThreadPoolExecutor;
@@ -27,8 +27,8 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Optional;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.annotation.Alias;
+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/limiter/broker/SharedLimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
index 0ae45a6..7d2a364 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
@@ -15,28 +15,28 @@
* limitations under the License.
*/
-package gobblin.util.limiter.broker;
+package org.apache.gobblin.util.limiter.broker;
import java.util.Collection;
import com.typesafe.config.Config;
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NoSuchScopeException;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.ResourceCoordinate;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.LimiterFactory;
-import gobblin.util.limiter.MultiLimiter;
-import gobblin.util.limiter.NoopLimiter;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NoSuchScopeException;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.ResourceCoordinate;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.LimiterFactory;
+import org.apache.gobblin.util.limiter.MultiLimiter;
+import org.apache.gobblin.util.limiter.NoopLimiter;
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/limiter/broker/SharedLimiterKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java
index 0d89e01..04e9a6a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.util.limiter.broker;
+package org.apache.gobblin.util.limiter.broker;
-import gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
import lombok.EqualsAndHashCode;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java
index 76c660e..e1559fd 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.logs;
+package org.apache.gobblin.util.logs;
import java.io.FileInputStream;
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/logs/LogCopier.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java
index 96795ad..9e4b957 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.logs;
+package org.apache.gobblin.util.logs;
import java.io.BufferedReader;
import java.io.BufferedWriter;
@@ -51,13 +51,13 @@ import com.google.common.io.Closer;
import com.google.common.io.Files;
import com.google.common.util.concurrent.AbstractScheduledService;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.util.concurrent.ScheduledTask;
-import gobblin.util.concurrent.TaskScheduler;
-import gobblin.util.concurrent.TaskSchedulerFactory;
-import gobblin.util.DatasetFilterUtils;
-import gobblin.util.FileListUtils;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.util.concurrent.ScheduledTask;
+import org.apache.gobblin.util.concurrent.TaskScheduler;
+import org.apache.gobblin.util.concurrent.TaskSchedulerFactory;
+import org.apache.gobblin.util.DatasetFilterUtils;
+import org.apache.gobblin.util.FileListUtils;
+import org.apache.gobblin.util.HadoopUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java
index 6950b61..f1b86ee 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.recordcount;
+package org.apache.gobblin.util.recordcount;
import java.util.Random;
import java.util.regex.Pattern;
@@ -24,7 +24,7 @@ import org.apache.hadoop.fs.Path;
import com.google.common.base.Preconditions;
-import gobblin.util.RecordCountProvider;
+import org.apache.gobblin.util.RecordCountProvider;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java
index 6ca3300..35f0664 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.recordcount;
+package org.apache.gobblin.util.recordcount;
import java.util.regex.Pattern;
@@ -25,7 +25,7 @@ import org.apache.hadoop.fs.Path;
import com.google.common.base.Preconditions;
import com.google.common.io.Files;
-import gobblin.util.RecordCountProvider;
+import org.apache.gobblin.util.RecordCountProvider;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java
index a90b55e..6a12ff5 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.recordcount;
+package org.apache.gobblin.util.recordcount;
import java.io.IOException;
import java.util.Random;
@@ -25,7 +25,7 @@ import org.apache.commons.io.FilenameUtils;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
-import gobblin.util.RecordCountProvider;
+import org.apache.gobblin.util.RecordCountProvider;
import lombok.AllArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java
index 1569b46..13791b2 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.util.reflection;
+package org.apache.gobblin.util.reflection;
import java.lang.reflect.InvocationTargetException;
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/request_allocation/AllocatedRequestsIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java
index 23e0bd3..f68c52e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
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/request_allocation/AllocatedRequestsIteratorBase.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java
index 2c7c307..a0e31d1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Iterator;
import java.util.Random;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java
index 8e87aaf..3df01b2 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
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/request_allocation/ConcurrentBoundedPriorityIterable.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java
index 306042c..c1a4505 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Comparator;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java
index 74e66c4..76cc600 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Iterator;
import java.util.concurrent.Callable;
@@ -23,7 +23,7 @@ import java.util.concurrent.Callable;
import com.google.common.base.Function;
import com.google.common.collect.Iterators;
-import gobblin.util.iterators.InterruptibleIterator;
+import org.apache.gobblin.util.iterators.InterruptibleIterator;
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/request_allocation/HierarchicalAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java
index 3301a2b..9b24e28 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Collections;
import java.util.Comparator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java
index 093b381..9703bb0 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Comparator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java
index 27fcb0e..f136bc3 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.io.IOException;
import java.util.Iterator;
@@ -24,7 +24,7 @@ import java.util.concurrent.Callable;
import com.google.common.collect.Lists;
-import gobblin.util.iterators.InterruptibleIterator;
+import org.apache.gobblin.util.iterators.InterruptibleIterator;
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/request_allocation/PriorityIterableBasedRequestAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java
index a3db8a3..876a4eb 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Iterator;
import java.util.List;
@@ -28,9 +28,9 @@ import com.google.common.base.Function;
import com.google.common.base.Optional;
import com.google.common.collect.Iterators;
-import gobblin.util.Either;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.executors.IteratorExecutor;
+import org.apache.gobblin.util.Either;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.executors.IteratorExecutor;
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/request_allocation/PriorityMultiIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java
index 71c09cd..e535245 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Collection;
import java.util.Comparator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java
index 27e2ddf..33df64e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.io.IOException;
import java.util.Comparator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java
index cb7f85f..67dc931 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
/**
* Represents an expensive request in the request allocation problem. See {@link RequestAllocator}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java
index b244007..f9bfe48 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Comparator;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java
index de09fad..b33070b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.io.Serializable;
import java.util.Comparator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java
index d1dc81c..d5fdf43 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import com.typesafe.config.Config;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ClassAliasResolver;
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/request_allocation/Requestor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java
index 88e0f71..b276ce9 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.io.IOException;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java
index 0da3817..ec59ef2 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import com.typesafe.config.Config;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java
index e849229..01ce129 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import java.util.Arrays;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java
index d0fb925..463dd8c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
import lombok.AccessLevel;
import lombok.AllArgsConstructor;