Change package from gobblin to org.apache.gobblin for classes extending gobblin classes
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/84901410 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/84901410 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/84901410 Branch: refs/heads/master Commit: 849014108a18ed92081b492858ff4b636509785c Parents: abc111c Author: Abhishek Tiwari <[email protected]> Authored: Sun Jul 30 19:31:51 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Sun Jul 30 19:31:51 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/gobblin/converter/EmptyIterable.java | 2 +- .../java/org/apache/gobblin/data/management/dataset/Dataset.java | 2 +- .../org/apache/gobblin/data/management/dataset/DatasetUtils.java | 2 +- .../data/management/retention/version/StringDatasetVersion.java | 2 +- .../management/retention/version/TimestampedDatasetVersion.java | 2 +- .../org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java | 2 +- .../src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java | 2 +- .../main/java/org/apache/gobblin/runtime/CountBasedLimiter.java | 2 +- .../java/org/apache/gobblin/runtime/DefaultLimiterFactory.java | 2 +- .../src/main/java/org/apache/gobblin/runtime/Limiter.java | 2 +- .../main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java | 2 +- .../src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java | 2 +- .../src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java | 2 +- .../src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java | 2 +- .../main/java/org/apache/gobblin/runtime/util/ClustersNames.java | 2 +- .../test/java/org/apache/gobblin/runtime/TaskContinuousTest.java | 2 +- 16 files changed, 16 insertions(+), 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java index a080d53..0ba91e6 100644 --- a/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java +++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java @@ -21,6 +21,6 @@ package org.apache.gobblin.converter; * @deprecated. Please use {@link org.apache.gobblin.util.EmptyIterable} instead. */ @Deprecated -public class EmptyIterable<T> extends gobblin.util.EmptyIterable<T> { +public class EmptyIterable<T> extends org.apache.gobblin.util.EmptyIterable<T> { } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java index 3996dbb..e5dd8dc 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java @@ -20,5 +20,5 @@ package org.apache.gobblin.data.management.dataset; /** * {@inheritDoc} */ -public interface Dataset extends gobblin.dataset.Dataset { +public interface Dataset extends org.apache.gobblin.dataset.Dataset { } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java index 0488ac9..2c1e954 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java @@ -71,7 +71,7 @@ public class DatasetUtils { * @throws IOException */ @SuppressWarnings("unchecked") - public static <T extends gobblin.dataset.Dataset> DatasetsFinder<T> instantiateDatasetFinder(Properties props, + public static <T extends org.apache.gobblin.dataset.Dataset> DatasetsFinder<T> instantiateDatasetFinder(Properties props, FileSystem fs, String default_class, Object... additionalArgs) throws IOException { String className = default_class; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java index 1c93b59..32410ff 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java @@ -28,7 +28,7 @@ import org.apache.hadoop.fs.Path; * {@link org.apache.gobblin.data.management.retention.version.DatasetVersion}. */ @Deprecated -public class StringDatasetVersion extends gobblin.data.management.version.StringDatasetVersion implements +public class StringDatasetVersion extends org.apache.gobblin.data.management.version.StringDatasetVersion implements DatasetVersion { public StringDatasetVersion(String version, Path path) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java index 7960694..9fc6deb 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java @@ -33,7 +33,7 @@ import com.google.common.collect.Lists; * {@link org.apache.gobblin.data.management.retention.version.DatasetVersion}. */ @Deprecated -public class TimestampedDatasetVersion extends gobblin.data.management.version.TimestampedDatasetVersion implements +public class TimestampedDatasetVersion extends org.apache.gobblin.data.management.version.TimestampedDatasetVersion implements DatasetVersion { public TimestampedDatasetVersion(DateTime version, Path path) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java index dba8488..95fae24 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java @@ -29,7 +29,7 @@ import org.apache.gobblin.password.PasswordManager; /** * This class extends {@link org.apache.gobblin.util.jdbc.DataSourceProvider} with its own property keys. */ -public class JobHistoryDataSourceProvider extends gobblin.util.jdbc.DataSourceProvider { +public class JobHistoryDataSourceProvider extends org.apache.gobblin.util.jdbc.DataSourceProvider { @Inject public JobHistoryDataSourceProvider(@Named("dataSourceProperties") Properties properties) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java index dbc266b..0e185c8 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java @@ -22,6 +22,6 @@ package org.apache.gobblin.azkaban; /** * Utility class for collecting metadata specific to a Azkaban runtime environment. */ -public class AzkabanTags extends gobblin.util.AzkabanTags { +public class AzkabanTags extends org.apache.gobblin.util.AzkabanTags { } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java index f3187b0..f3b8258 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java @@ -24,7 +24,7 @@ package org.apache.gobblin.runtime; * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.CountBasedLimiter}. */ @Deprecated -public class CountBasedLimiter extends gobblin.util.limiter.CountBasedLimiter { +public class CountBasedLimiter extends org.apache.gobblin.util.limiter.CountBasedLimiter { public CountBasedLimiter(long countLimit) { super(countLimit); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java index 82d41cb..c1648d2 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java @@ -23,5 +23,5 @@ package org.apache.gobblin.runtime; * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.DefaultLimiterFactory}. */ @Deprecated -public class DefaultLimiterFactory extends gobblin.util.limiter.DefaultLimiterFactory { +public class DefaultLimiterFactory extends org.apache.gobblin.util.limiter.DefaultLimiterFactory { } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java index 5184365..e30e8e2 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java @@ -24,5 +24,5 @@ package org.apache.gobblin.runtime; * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.Limiter}. */ @Deprecated -public interface Limiter extends gobblin.util.limiter.Limiter { +public interface Limiter extends org.apache.gobblin.util.limiter.Limiter { } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java index 9361c75..611df4e 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java @@ -24,5 +24,5 @@ package org.apache.gobblin.runtime; * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.NonRefillableLimiter}. */ @Deprecated -public abstract class NonRefillableLimiter extends gobblin.util.limiter.NonRefillableLimiter { +public abstract class NonRefillableLimiter extends org.apache.gobblin.util.limiter.NonRefillableLimiter { } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java index b73c3c0..627778f 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java @@ -24,7 +24,7 @@ package org.apache.gobblin.runtime; * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.PoolBasedLimiter}. */ @Deprecated -public class PoolBasedLimiter extends gobblin.util.limiter.PoolBasedLimiter { +public class PoolBasedLimiter extends org.apache.gobblin.util.limiter.PoolBasedLimiter { public PoolBasedLimiter(int poolSize) { super(poolSize); } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java index c2b4c9a..2f6f8da 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java @@ -26,7 +26,7 @@ import java.util.concurrent.TimeUnit; * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.RateBasedLimiter}. */ @Deprecated -public class RateBasedLimiter extends gobblin.util.limiter.RateBasedLimiter { +public class RateBasedLimiter extends org.apache.gobblin.util.limiter.RateBasedLimiter { public RateBasedLimiter(double rateLimit) { super(rateLimit); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java index ec11e5c..6ff3e8b 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java @@ -26,7 +26,7 @@ import java.util.concurrent.TimeUnit; * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.TimeBasedLimiter}. */ @Deprecated -public class TimeBasedLimiter extends gobblin.util.limiter.TimeBasedLimiter { +public class TimeBasedLimiter extends org.apache.gobblin.util.limiter.TimeBasedLimiter { public TimeBasedLimiter(long timeLimit) { super(timeLimit); } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java index 8d19028..4accaaf 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java @@ -27,7 +27,7 @@ package org.apache.gobblin.runtime.util; * <p><b>IMPORTANT:</b> Don't forget to escape colons ":" in the file as those may be interpreted * as name/value separators. */ -public class ClustersNames extends gobblin.util.ClustersNames { +public class ClustersNames extends org.apache.gobblin.util.ClustersNames { private static ClustersNames THE_INSTANCE; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/84901410/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java index fa917fd..f7fb41a 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java @@ -454,7 +454,7 @@ public class TaskContinuousTest { } - private class TestStreamingDataWriterBuilder extends gobblin.writer.DataWriterBuilder { + private class TestStreamingDataWriterBuilder extends org.apache.gobblin.writer.DataWriterBuilder { private final List<Object> _recordCollector;
