Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 1839F200CEC for ; Mon, 31 Jul 2017 09:52:27 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 16AA1164970; Mon, 31 Jul 2017 07:52:27 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 47D2C164964 for ; Mon, 31 Jul 2017 09:52:24 +0200 (CEST) Received: (qmail 16476 invoked by uid 500); 31 Jul 2017 07:52:23 -0000 Mailing-List: contact commits-help@gobblin.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@gobblin.incubator.apache.org Delivered-To: mailing list commits@gobblin.incubator.apache.org Received: (qmail 15792 invoked by uid 99); 31 Jul 2017 07:52:22 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 31 Jul 2017 07:52:22 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id EA163F335F; Mon, 31 Jul 2017 07:52:19 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: abti@apache.org To: commits@gobblin.apache.org Date: Mon, 31 Jul 2017 07:52:21 -0000 Message-Id: In-Reply-To: <50c2ce484ba041a294296078b24418ae@git.apache.org> References: <50c2ce484ba041a294296078b24418ae@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [03/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts archived-at: Mon, 31 Jul 2017 07:52:27 -0000 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;