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:11 UTC
[53/77] [abbrv] incubator-gobblin git commit: Change package from
gobblin to org.apache.gobblin for fully qualified object initialization
Change package from gobblin to org.apache.gobblin for fully qualified object initialization
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/13adbef8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/13adbef8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/13adbef8
Branch: refs/heads/master
Commit: 13adbef86b5a5c50a4d975018504c9c432ef6695
Parents: fcfad77
Author: Abhishek Tiwari <ab...@gmail.com>
Authored: Sun Jul 30 19:27:15 2017 -0700
Committer: Abhishek Tiwari <ab...@gmail.com>
Committed: Sun Jul 30 19:27:15 2017 -0700
----------------------------------------------------------------------
.../retention/version/finder/DateTimeDatasetVersionFinder.java | 2 +-
.../version/finder/FileLevelTimestampVersionFinder.java | 2 +-
.../version/finder/GlobModTimeDatasetVersionFinder.java | 2 +-
.../version/finder/ModDateTimeDatasetVersionFinder.java | 2 +-
.../retention/version/finder/UnixTimestampVersionFinder.java | 2 +-
.../version/finder/WatermarkDatasetVersionFinder.java | 2 +-
.../gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java | 6 +++---
.../org/apache/gobblin/metrics/GobblinTrackingEvent.java | 6 +++---
.../src/main/gen-java/org/apache/gobblin/metrics/Metric.java | 6 +++---
.../main/gen-java/org/apache/gobblin/metrics/MetricReport.java | 6 +++---
.../runtime/instance/DefaultGobblinInstanceDriverImpl.java | 2 +-
.../runtime/instance/StandardGobblinInstanceDriver.java | 2 +-
.../runtime/instance/StandardGobblinInstanceLauncher.java | 2 +-
.../org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java | 2 +-
.../gobblin/runtime/job_exec/JobLauncherExecutionDriver.java | 2 +-
.../org/apache/gobblin/runtime/kafka/HighLevelConsumer.java | 2 +-
.../org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java | 2 +-
.../apache/gobblin/runtime/spec_catalog/TopologyCatalog.java | 2 +-
18 files changed, 26 insertions(+), 26 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
index 8a78d85..19b9b8c 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
@@ -52,7 +52,7 @@ public class DateTimeDatasetVersionFinder extends DatasetVersionFinder<Timestamp
public DateTimeDatasetVersionFinder(FileSystem fs, Properties props) {
super(fs, convertDeprecatedProperties(props));
- this.realVersionFinder = new gobblin.data.management.version.finder.DateTimeDatasetVersionFinder(fs, convertDeprecatedProperties(props));
+ this.realVersionFinder = new org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder(fs, convertDeprecatedProperties(props));
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
index 2963fdb..6bebe0b 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
@@ -38,7 +38,7 @@ public class FileLevelTimestampVersionFinder implements VersionFinder<Timestampe
private final gobblin.data.management.version.finder.FileLevelTimestampVersionFinder realVersionFinder;
public FileLevelTimestampVersionFinder(FileSystem fs, Properties props) {
this.realVersionFinder =
- new gobblin.data.management.version.finder.FileLevelTimestampVersionFinder(fs,props);
+ new org.apache.gobblin.data.management.version.finder.FileLevelTimestampVersionFinder(fs,props);
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
index aded4b2..fb3cbf1 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
@@ -42,7 +42,7 @@ public class GlobModTimeDatasetVersionFinder extends DatasetVersionFinder<Timest
public GlobModTimeDatasetVersionFinder(FileSystem fs, Path globPattern) {
super(fs);
this.realVersionFinder =
- new gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder(fs, globPattern);
+ new org.apache.gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder(fs, globPattern);
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
index f1e5de8..79622e7 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
@@ -38,7 +38,7 @@ public class ModDateTimeDatasetVersionFinder implements VersionFinder<Timestampe
private final gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder realVersionFinder;
public ModDateTimeDatasetVersionFinder(FileSystem fs, Properties props) {
- this.realVersionFinder = new gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder(fs, props);
+ this.realVersionFinder = new org.apache.gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder(fs, props);
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
index bd9ba12..1f66f48 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
@@ -38,7 +38,7 @@ public class UnixTimestampVersionFinder extends DatasetVersionFinder<Timestamped
public UnixTimestampVersionFinder(FileSystem fs, Properties props) {
super(fs, props);
this.realVersionFinder =
- new gobblin.data.management.version.finder.UnixTimestampVersionFinder(fs, convertDeprecatedProperties(props));
+ new org.apache.gobblin.data.management.version.finder.UnixTimestampVersionFinder(fs, convertDeprecatedProperties(props));
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
index 80e8c14..44e9d21 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
@@ -43,7 +43,7 @@ public class WatermarkDatasetVersionFinder extends DatasetVersionFinder<StringDa
public WatermarkDatasetVersionFinder(FileSystem fs, Properties props) {
super(fs, props);
this.realVersionFinder =
- new gobblin.data.management.version.finder.WatermarkDatasetVersionFinder(fs, convertDeprecatedProperties(props));
+ new org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder(fs, convertDeprecatedProperties(props));
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
index d6e8a70..d07312a 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
@@ -140,7 +140,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa
* @return A new FlatGobblinMetric RecordBuilder
*/
public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder() {
- return new gobblin.metrics.FlatGobblinMetric.Builder();
+ return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder();
}
/**
@@ -149,7 +149,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa
* @return A new FlatGobblinMetric RecordBuilder
*/
public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder(gobblin.metrics.FlatGobblinMetric.Builder other) {
- return new gobblin.metrics.FlatGobblinMetric.Builder(other);
+ return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder(other);
}
/**
@@ -158,7 +158,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa
* @return A new FlatGobblinMetric RecordBuilder
*/
public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder(gobblin.metrics.FlatGobblinMetric other) {
- return new gobblin.metrics.FlatGobblinMetric.Builder(other);
+ return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder(other);
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
index 59c956c..a6dbaed 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
@@ -140,7 +140,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor
* @return A new GobblinTrackingEvent RecordBuilder
*/
public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder() {
- return new gobblin.metrics.GobblinTrackingEvent.Builder();
+ return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder();
}
/**
@@ -149,7 +149,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor
* @return A new GobblinTrackingEvent RecordBuilder
*/
public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder(gobblin.metrics.GobblinTrackingEvent.Builder other) {
- return new gobblin.metrics.GobblinTrackingEvent.Builder(other);
+ return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder(other);
}
/**
@@ -158,7 +158,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor
* @return A new GobblinTrackingEvent RecordBuilder
*/
public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder(gobblin.metrics.GobblinTrackingEvent other) {
- return new gobblin.metrics.GobblinTrackingEvent.Builder(other);
+ return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder(other);
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
index 1160507..fd5618d 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
@@ -94,7 +94,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen
* @return A new Metric RecordBuilder
*/
public static gobblin.metrics.Metric.Builder newBuilder() {
- return new gobblin.metrics.Metric.Builder();
+ return new org.apache.gobblin.metrics.Metric.Builder();
}
/**
@@ -103,7 +103,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen
* @return A new Metric RecordBuilder
*/
public static gobblin.metrics.Metric.Builder newBuilder(gobblin.metrics.Metric.Builder other) {
- return new gobblin.metrics.Metric.Builder(other);
+ return new org.apache.gobblin.metrics.Metric.Builder(other);
}
/**
@@ -112,7 +112,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen
* @return A new Metric RecordBuilder
*/
public static gobblin.metrics.Metric.Builder newBuilder(gobblin.metrics.Metric other) {
- return new gobblin.metrics.Metric.Builder(other);
+ return new org.apache.gobblin.metrics.Metric.Builder(other);
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
index 6cbf097..22bf9b9 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
@@ -117,7 +117,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im
* @return A new MetricReport RecordBuilder
*/
public static gobblin.metrics.MetricReport.Builder newBuilder() {
- return new gobblin.metrics.MetricReport.Builder();
+ return new org.apache.gobblin.metrics.MetricReport.Builder();
}
/**
@@ -126,7 +126,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im
* @return A new MetricReport RecordBuilder
*/
public static gobblin.metrics.MetricReport.Builder newBuilder(gobblin.metrics.MetricReport.Builder other) {
- return new gobblin.metrics.MetricReport.Builder(other);
+ return new org.apache.gobblin.metrics.MetricReport.Builder(other);
}
/**
@@ -135,7 +135,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im
* @return A new MetricReport RecordBuilder
*/
public static gobblin.metrics.MetricReport.Builder newBuilder(gobblin.metrics.MetricReport other) {
- return new gobblin.metrics.MetricReport.Builder(other);
+ return new org.apache.gobblin.metrics.MetricReport.Builder(other);
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
index d508e16..939f251 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
@@ -105,7 +105,7 @@ public class DefaultGobblinInstanceDriverImpl extends AbstractIdleService
}
private MetricContext constructMetricContext(Configurable sysConfig, Logger log) {
- gobblin.configuration.State tmpState = new gobblin.configuration.State(sysConfig.getConfigAsProperties());
+ gobblin.configuration.State tmpState = new org.apache.gobblin.configuration.State(sysConfig.getConfigAsProperties());
return GobblinMetrics.isEnabled(sysConfig.getConfig()) ?
Instrumented.getMetricContext(tmpState, getClass())
: null;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
index dc9df98..1daffaf 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
@@ -349,7 +349,7 @@ public class StandardGobblinInstanceDriver extends DefaultGobblinInstanceDriverI
public MetricContext getDefaultMetricContext() {
gobblin.configuration.State fakeState =
- new gobblin.configuration.State(getSysConfig().getConfigAsProperties());
+ new org.apache.gobblin.configuration.State(getSysConfig().getConfigAsProperties());
List<Tag<?>> tags = new ArrayList<>();
tags.add(new Tag<>(StandardMetrics.INSTANCE_NAME_TAG, getInstanceName()));
MetricContext res = Instrumented.getMetricContext(fakeState,
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
index 69889dd..a4efcdd 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
@@ -224,7 +224,7 @@ public class StandardGobblinInstanceLauncher extends AbstractIdleService
private MetricContext getDefaultMetricContext() {
gobblin.configuration.State fakeState =
- new gobblin.configuration.State(getSysConfig().getConfigAsProperties());
+ new org.apache.gobblin.configuration.State(getSysConfig().getConfigAsProperties());
return Instrumented.getMetricContext(fakeState, StandardGobblinInstanceLauncher.class);
}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
index 8abf914..545edad 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
@@ -66,7 +66,7 @@ public abstract class JobCatalogBase extends AbstractIdleService implements JobC
this.listeners = new JobCatalogListenersList(log);
if (instrumentationEnabled) {
MetricContext realParentCtx =
- parentMetricContext.or(Instrumented.getMetricContext(new gobblin.configuration.State(), getClass()));
+ parentMetricContext.or(Instrumented.getMetricContext(new org.apache.gobblin.configuration.State(), getClass()));
this.metricContext = realParentCtx.childBuilder(JobCatalog.class.getSimpleName()).build();
this.metrics = new StandardMetrics(this);
}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
index 864abf4..c126ab2 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
@@ -435,7 +435,7 @@ public class JobLauncherExecutionDriver extends FutureTask<JobExecutionResult> i
.childBuilder(JobExecutionLauncher.class.getSimpleName()).build();
}
gobblin.configuration.State fakeState =
- new gobblin.configuration.State(getSysConfig().getConfigAsProperties());
+ new org.apache.gobblin.configuration.State(getSysConfig().getConfigAsProperties());
List<Tag<?>> tags = new ArrayList<>();
MetricContext res = Instrumented.getMetricContext(fakeState, Launcher.class, tags);
return res;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
index a619582..da2ac81 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
@@ -98,7 +98,7 @@ public abstract class HighLevelConsumer<K, V> extends AbstractIdleService {
*/
@VisibleForTesting
protected void buildMetricsContextAndMetrics() {
- this.metricContext = Instrumented.getMetricContext(new gobblin.configuration.State(ConfigUtils.configToProperties(config)),
+ this.metricContext = Instrumented.getMetricContext(new org.apache.gobblin.configuration.State(ConfigUtils.configToProperties(config)),
this.getClass(), getTagsForMetrics());
createMetrics();
}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
index 8abfc42..c0ad68a 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
@@ -85,7 +85,7 @@ public class FlowCatalog extends AbstractIdleService implements SpecCatalog, Mut
this.listeners = new SpecCatalogListenersList(log);
if (instrumentationEnabled) {
MetricContext realParentCtx =
- parentMetricContext.or(Instrumented.getMetricContext(new gobblin.configuration.State(), getClass()));
+ parentMetricContext.or(Instrumented.getMetricContext(new org.apache.gobblin.configuration.State(), getClass()));
this.metricContext = realParentCtx.childBuilder(FlowCatalog.class.getSimpleName()).build();
this.metrics = new StandardMetrics(this);
}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
index 057ef7c..e3bb988 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
@@ -86,7 +86,7 @@ public class TopologyCatalog extends AbstractIdleService implements SpecCatalog,
this.listeners = new SpecCatalogListenersList(log);
if (instrumentationEnabled) {
MetricContext realParentCtx =
- parentMetricContext.or(Instrumented.getMetricContext(new gobblin.configuration.State(), getClass()));
+ parentMetricContext.or(Instrumented.getMetricContext(new org.apache.gobblin.configuration.State(), getClass()));
this.metricContext = realParentCtx.childBuilder(TopologyCatalog.class.getSimpleName()).build();
this.metrics = new SpecCatalog.StandardMetrics(this);
}