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 <[email protected]> Authored: Sun Jul 30 19:27:15 2017 -0700 Committer: Abhishek Tiwari <[email protected]> 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); }
