Change package from gobblin to org.apache.gobblin for classes implementing 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/f68e2362 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/f68e2362 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/f68e2362 Branch: refs/heads/master Commit: f68e2362f8c9df53f33592e5bd1c1157a0bd3598 Parents: 8490141 Author: Abhishek Tiwari <[email protected]> Authored: Sun Jul 30 19:32:36 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Sun Jul 30 19:32:36 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/gobblin/compaction/dataset/DatasetsFinder.java | 2 +- .../org/apache/gobblin/compliance/HivePartitionVersionFinder.java | 2 +- .../org/apache/gobblin/task/EventBusPublishingTaskFactory.java | 2 +- .../java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/f68e2362/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetsFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetsFinder.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetsFinder.java index 26fb8e3..cd56460 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetsFinder.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetsFinder.java @@ -46,7 +46,7 @@ import org.apache.gobblin.util.HadoopUtils; /** * {@link Dataset}s finder to identify datasets, using given properties. */ -public abstract class DatasetsFinder implements gobblin.dataset.DatasetsFinder<Dataset> { +public abstract class DatasetsFinder implements org.apache.gobblin.dataset.DatasetsFinder<Dataset> { public static final double HIGH_PRIORITY = 3.0; public static final double NORMAL_PRIORITY = 2.0; public static final double LOW_PRIORITY = 1.0; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/f68e2362/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java index b13716b..25f86cf 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java @@ -52,7 +52,7 @@ import org.apache.gobblin.util.AutoReturnableObject; * @author adsharma */ @Slf4j -public class HivePartitionVersionFinder implements gobblin.data.management.version.finder.VersionFinder<HivePartitionVersion> { +public class HivePartitionVersionFinder implements org.apache.gobblin.data.management.version.finder.VersionFinder<HivePartitionVersion> { protected final FileSystem fs; protected final State state; protected List<String> patterns; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/f68e2362/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java b/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java index f4168df..f14bbda 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java @@ -99,7 +99,7 @@ public class EventBusPublishingTaskFactory implements TaskFactory { } } - public static class Source implements gobblin.source.Source<String, String> { + public static class Source implements org.apache.gobblin.source.Source<String, String> { public static final String NUM_TASKS_KEY = "num.tasks"; @Override http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/f68e2362/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java index 97f401f..c5031fe 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java @@ -175,7 +175,7 @@ public class SharedResourcesBrokerImpl<S extends ScopeType<S>> implements Shared * A builder used to create a descendant {@link SharedResourcesBrokerImpl} with the same backing {@link DefaultBrokerCache}. */ @NotThreadSafe - public class SubscopedBrokerBuilder implements gobblin.broker.iface.SubscopedBrokerBuilder<S, SharedResourcesBrokerImpl<S>> { + public class SubscopedBrokerBuilder implements org.apache.gobblin.broker.iface.SubscopedBrokerBuilder<S, SharedResourcesBrokerImpl<S>> { private final ScopeInstance<S> scope; private final Map<S, ScopeWrapper<S>> ancestorScopes = Maps.newHashMap(); private Config config = ConfigFactory.empty();
