You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:53:13 UTC
[55/77] [abbrv] incubator-gobblin git commit: Change package from
gobblin to org.apache.gobblin for classes extending gobblin classes
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 <ab...@gmail.com>
Authored: Sun Jul 30 19:31:51 2017 -0700
Committer: Abhishek Tiwari <ab...@gmail.com>
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;