gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [56/77] [abbrv] incubator-gobblin git commit: Change package from gobblin to org.apache.gobblin for classes implementing gobblin classes
Date Mon, 31 Jul 2017 07:53:14 GMT
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 <abhishektiwari.btech@gmail.com>
Authored: Sun Jul 30 19:32:36 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
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();


Mime
View raw message