http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset.conf ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset.conf b/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset.conf index e910d4a..5a7afda 100644 --- a/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset.conf +++ b/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset.conf @@ -5,11 +5,11 @@ daily: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 730 } version: { - finder.class = gobblin.data.management.version.finder.DateTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder globPattern = "*/*/*" datetime.pattern = "yyyy/MM/dd" } @@ -17,11 +17,11 @@ hourly: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 360 } version: { - finder.class = gobblin.data.management.version.finder.DateTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder globPattern = "*/*/*/*" datetime.pattern = "yyyy/MM/dd/HH" } @@ -29,22 +29,22 @@ snapshot: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 3 } version: { - finder.class = gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder version.globPattern = "*" } } sync: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 1 } version: { - finder.class = gobblin.data.management.version.finder.SingleVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.SingleVersionFinder } } } @@ -58,11 +58,11 @@ name:profileTest } - source { + source { hadoopfs{ cluster.colo:coloX cluster.name: cluster1 - cluster.FsURI:"hdfs://coloX-cluster1nn01.grid.com:9000" + cluster.FsURI:"hdfs://coloX-cluster1nn01.grid.com:9000" path:/jobs/mitu/profileTest } } @@ -91,7 +91,7 @@ cluster.name: cluster1 cluster.FsURI:"hdfs://coloX-cluster1nn01.grid.com:9000" path:/data/derived/oncluster1 - } + } }, replica2{ hadoopfs{ @@ -99,9 +99,9 @@ cluster.name: cluster2 cluster.FsURI:"hdfs://coloX-cluster2nn01.grid.com:9000" path:/data/derived/oncluster2 - } + } }, - } + } dataFlowTopology { routes{ @@ -111,5 +111,5 @@ replica3:[replica4,replica2,replica1,source] } } - + }
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PullMode2.conf ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PullMode2.conf b/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PullMode2.conf index a7247d9..02d288f 100644 --- a/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PullMode2.conf +++ b/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PullMode2.conf @@ -5,11 +5,11 @@ daily: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 730 } version: { - finder.class = gobblin.data.management.version.finder.DateTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder globPattern = "*/*/*" datetime.pattern = "yyyy/MM/dd" } @@ -17,11 +17,11 @@ hourly: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 360 } version: { - finder.class = gobblin.data.management.version.finder.DateTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder globPattern = "*/*/*/*" datetime.pattern = "yyyy/MM/dd/HH" } @@ -29,22 +29,22 @@ snapshot: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 3 } version: { - finder.class = gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder version.globPattern = "*" } } sync: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 1 } version: { - finder.class = gobblin.data.management.version.finder.SingleVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.SingleVersionFinder } } } @@ -56,7 +56,7 @@ # source data generated on replica4 cluster4{ routes{ - # copy to replica4 + # copy to replica4 replica4:[source] replica3:[replica4,source] replica2:[replica3,replica4,source] @@ -99,11 +99,11 @@ name:profileTest } - source { + source { hadoopfs{ cluster.colo:coloX cluster.name: cluster1 - cluster.FsURI:"hdfs://coloX-cluster1nn01.grid.com:9000" + cluster.FsURI:"hdfs://coloX-cluster1nn01.grid.com:9000" path:/jobs/mitu/profileTest } } @@ -132,7 +132,7 @@ cluster.name: cluster1 cluster.FsURI:"hdfs://coloX-cluster1nn01.grid.com:9000" path:/data/derived/oncluster1 - } + } }, replica2{ hadoopfs{ @@ -140,11 +140,11 @@ cluster.name: cluster2 cluster.FsURI:"hdfs://coloX-cluster2nn01.grid.com:9000" path:/data/derived/oncluster2 - } + } }, - } + } dataFlowTopology { } - + } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode.conf ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode.conf b/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode.conf index d0dea7f..17473d3 100644 --- a/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode.conf +++ b/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode.conf @@ -4,11 +4,11 @@ daily: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 730 } version: { - finder.class = gobblin.data.management.version.finder.DateTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder globPattern = "*/*/*" datetime.pattern = "yyyy/MM/dd" } @@ -16,11 +16,11 @@ hourly: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 360 } version: { - finder.class = gobblin.data.management.version.finder.DateTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder globPattern = "*/*/*/*" datetime.pattern = "yyyy/MM/dd/HH" } @@ -28,22 +28,22 @@ snapshot: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 3 } version: { - finder.class = gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder version.globPattern = "*" } } sync: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 1 } version: { - finder.class = gobblin.data.management.version.finder.SingleVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.SingleVersionFinder } } } @@ -66,7 +66,7 @@ } cluster2{ FsURI:"hdfs://coloX-cluster2nn01.grid.com:9000" - colo:coloX + colo:coloX name:cluster2 } cluster1{ @@ -82,7 +82,7 @@ name:profileTest } - source { + source { hadoopfs{ cluster:${clusters.cluster1} path:/jobs/mitu/profileTest @@ -107,15 +107,15 @@ hadoopfs{ cluster:${clusters.cluster1} path:/data/derived/oncluster1 - } + } }, replica2 { hadoopfs{ cluster:${clusters.cluster2} path:/data/derived/oncluster2 - } + } }, - } + } dataFlowTopology { routes{ @@ -125,5 +125,5 @@ replica4:[replica3] } } - + } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode2.conf ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode2.conf b/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode2.conf index 7f780c3..9cffd8e 100644 --- a/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode2.conf +++ b/gobblin-data-management/src/test/resources/replicationConfigTest/validCompleteDataset_PushMode2.conf @@ -4,11 +4,11 @@ daily: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 730 } version: { - finder.class = gobblin.data.management.version.finder.DateTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder globPattern = "*/*/*" datetime.pattern = "yyyy/MM/dd" } @@ -16,11 +16,11 @@ hourly: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 360 } version: { - finder.class = gobblin.data.management.version.finder.DateTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder globPattern = "*/*/*/*" datetime.pattern = "yyyy/MM/dd/HH" } @@ -28,22 +28,22 @@ snapshot: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 3 } version: { - finder.class = gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder version.globPattern = "*" } } sync: { selection : { - policy.class = gobblin.data.management.policy.NewestKSelectionPolicy + policy.class = org.apache.gobblin.data.management.policy.NewestKSelectionPolicy newestK.versionsSelected = 1 } version: { - finder.class = gobblin.data.management.version.finder.SingleVersionFinder + finder.class = org.apache.gobblin.data.management.version.finder.SingleVersionFinder } } } @@ -96,7 +96,7 @@ } cluster2{ FsURI:"hdfs://coloX-cluster2nn01.grid.com:9000" - colo:coloX + colo:coloX name:cluster2 } cluster1{ @@ -112,7 +112,7 @@ name:profileTest } - source { + source { hadoopfs{ cluster:${clusters.cluster1} path:/jobs/mitu/profileTest @@ -137,17 +137,17 @@ hadoopfs{ cluster:${clusters.cluster1} path:/data/derived/oncluster1 - } + } }, replica2 { hadoopfs{ cluster:${clusters.cluster2} path:/data/derived/oncluster2 - } + } }, - } + } dataFlowTopology { } - + } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-data-management/src/test/resources/retentionIntegrationTest/testCombinePolicy/selection.conf ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/resources/retentionIntegrationTest/testCombinePolicy/selection.conf b/gobblin-data-management/src/test/resources/retentionIntegrationTest/testCombinePolicy/selection.conf index 8f521ae..79dd7e7 100644 --- a/gobblin-data-management/src/test/resources/retentionIntegrationTest/testCombinePolicy/selection.conf +++ b/gobblin-data-management/src/test/resources/retentionIntegrationTest/testCombinePolicy/selection.conf @@ -10,8 +10,8 @@ gobblin.retention : { policy.class=org.apache.gobblin.data.management.policy.CombineSelectionPolicy combine.operation=INTERSECT combine.policy.classes=[ - gobblin.data.management.policy.SelectBeforeTimeBasedPolicy, - gobblin.data.management.policy.NewestKSelectionPolicy + org.apache.gobblin.data.management.policy.SelectBeforeTimeBasedPolicy, + org.apache.gobblin.data.management.policy.NewestKSelectionPolicy ] timeBased.lookbackTime=3d newestK.versionsNotSelected=2 http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-docs/data-management/Gobblin-Retention.md ---------------------------------------------------------------------- diff --git a/gobblin-docs/data-management/Gobblin-Retention.md b/gobblin-docs/data-management/Gobblin-Retention.md index 0a3eb64..d083571 100644 --- a/gobblin-docs/data-management/Gobblin-Retention.md +++ b/gobblin-docs/data-management/Gobblin-Retention.md @@ -210,8 +210,8 @@ gobblin.retention : { policy.class=org.apache.gobblin.data.management.policy.CombineSelectionPolicy combine.operation=INTERSECT combine.policy.classes=[ - gobblin.data.management.policy.SelectBeforeTimeBasedPolicy, - gobblin.data.management.policy.NewestKSelectionPolicy + org.apache.gobblin.data.management.policy.SelectBeforeTimeBasedPolicy, + org.apache.gobblin.data.management.policy.NewestKSelectionPolicy ] timeBased.lookbackTime=3d newestK.versionsNotSelected=2 http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java ---------------------------------------------------------------------- diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java index 728b78f..3274fa1 100644 --- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java +++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java @@ -84,7 +84,7 @@ public class HiveRegistrationPolicyBase implements HiveRegistrationPolicy { // .. will be replaced by the table name determined via {@link #getTableName(Path)} public static final String PRIMARY_TABLE_TOKEN = "$PRIMARY_TABLE"; protected static final ConfigClient configClient = - gobblin.config.client.ConfigClient.createConfigClient(VersionStabilityPolicy.WEAK_LOCAL_STABILITY); + org.apache.gobblin.config.client.ConfigClient.createConfigClient(VersionStabilityPolicy.WEAK_LOCAL_STABILITY); /** * A valid db or table name should start with an alphanumeric character, and contains only http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java index 986cd90..50e3299 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatabaseJobHistoryStore.java @@ -59,7 +59,7 @@ import org.reflections.util.ConfigurationBuilder; * @author Yinan Li */ public class DatabaseJobHistoryStore implements JobHistoryStore { - // Scan all packages in the classpath with prefix gobblin.metastore.database when + // Scan all packages in the classpath with prefix org.apache.gobblin.metastore.database when // class is loaded. Since scan is expensive we do it only once when class is loaded. private static final Reflections reflections = new Reflections(getConfigurationBuilder()); private final VersionedDatabaseJobHistoryStore versionedStore; @@ -103,7 +103,7 @@ public class DatabaseJobHistoryStore implements JobHistoryStore { } private static Configuration getConfigurationBuilder() { - ConfigurationBuilder configurationBuilder= ConfigurationBuilder.build("gobblin.metastore.database", + ConfigurationBuilder configurationBuilder= ConfigurationBuilder.build("org.apache.gobblin.metastore.database", effectiveClassPathUrls(DatabaseJobHistoryStore.class.getClassLoader())); List<URL> filteredUrls = Lists.newArrayList(Iterables.filter(configurationBuilder.getUrls(), new Predicate<URL>() { @Override http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/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 d07312a..f417d11 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 @@ -139,7 +139,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * Creates a new FlatGobblinMetric RecordBuilder. * @return A new FlatGobblinMetric RecordBuilder */ - public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder() { + public static org.apache.gobblin.metrics.FlatGobblinMetric.Builder newBuilder() { return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder(); } @@ -148,7 +148,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * @param other The existing builder to copy. * @return A new FlatGobblinMetric RecordBuilder */ - public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder(gobblin.metrics.FlatGobblinMetric.Builder other) { + public static org.apache.gobblin.metrics.FlatGobblinMetric.Builder newBuilder(gobblin.metrics.FlatGobblinMetric.Builder other) { return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder(other); } @@ -157,7 +157,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * @param other The existing instance to copy. * @return A new FlatGobblinMetric RecordBuilder */ - public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder(gobblin.metrics.FlatGobblinMetric other) { + public static org.apache.gobblin.metrics.FlatGobblinMetric.Builder newBuilder(gobblin.metrics.FlatGobblinMetric other) { return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder(other); } @@ -244,7 +244,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * @param value The value of 'tags'. * @return This builder. */ - public gobblin.metrics.FlatGobblinMetric.Builder setTags(java.util.List<java.lang.String> value) { + public org.apache.gobblin.metrics.FlatGobblinMetric.Builder setTags(java.util.List<java.lang.String> value) { validate(fields()[0], value); this.tags = value; fieldSetFlags()[0] = true; @@ -266,7 +266,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * Tags associated with the metrics in the form key:value. * @return This builder. */ - public gobblin.metrics.FlatGobblinMetric.Builder clearTags() { + public org.apache.gobblin.metrics.FlatGobblinMetric.Builder clearTags() { tags = null; fieldSetFlags()[0] = false; return this; @@ -287,7 +287,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * @param value The value of 'timestamp'. * @return This builder. */ - public gobblin.metrics.FlatGobblinMetric.Builder setTimestamp(long value) { + public org.apache.gobblin.metrics.FlatGobblinMetric.Builder setTimestamp(long value) { validate(fields()[1], value); this.timestamp = value; fieldSetFlags()[1] = true; @@ -309,7 +309,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * Time at which metrics were reported. * @return This builder. */ - public gobblin.metrics.FlatGobblinMetric.Builder clearTimestamp() { + public org.apache.gobblin.metrics.FlatGobblinMetric.Builder clearTimestamp() { fieldSetFlags()[1] = false; return this; } @@ -329,7 +329,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * @param value The value of 'metricName'. * @return This builder. */ - public gobblin.metrics.FlatGobblinMetric.Builder setMetricName(java.lang.String value) { + public org.apache.gobblin.metrics.FlatGobblinMetric.Builder setMetricName(java.lang.String value) { validate(fields()[2], value); this.metricName = value; fieldSetFlags()[2] = true; @@ -351,7 +351,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * The name of this metric. * @return This builder. */ - public gobblin.metrics.FlatGobblinMetric.Builder clearMetricName() { + public org.apache.gobblin.metrics.FlatGobblinMetric.Builder clearMetricName() { metricName = null; fieldSetFlags()[2] = false; return this; @@ -372,7 +372,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * @param value The value of 'metricValue'. * @return This builder. */ - public gobblin.metrics.FlatGobblinMetric.Builder setMetricValue(double value) { + public org.apache.gobblin.metrics.FlatGobblinMetric.Builder setMetricValue(double value) { validate(fields()[3], value); this.metricValue = value; fieldSetFlags()[3] = true; @@ -394,7 +394,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa * The value of this metric. * @return This builder. */ - public gobblin.metrics.FlatGobblinMetric.Builder clearMetricValue() { + public org.apache.gobblin.metrics.FlatGobblinMetric.Builder clearMetricValue() { fieldSetFlags()[3] = false; return this; } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/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 a6dbaed..46b1220 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 @@ -139,7 +139,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * Creates a new GobblinTrackingEvent RecordBuilder. * @return A new GobblinTrackingEvent RecordBuilder */ - public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder() { + public static org.apache.gobblin.metrics.GobblinTrackingEvent.Builder newBuilder() { return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder(); } @@ -148,7 +148,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * @param other The existing builder to copy. * @return A new GobblinTrackingEvent RecordBuilder */ - public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder(gobblin.metrics.GobblinTrackingEvent.Builder other) { + public static org.apache.gobblin.metrics.GobblinTrackingEvent.Builder newBuilder(gobblin.metrics.GobblinTrackingEvent.Builder other) { return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder(other); } @@ -157,7 +157,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * @param other The existing instance to copy. * @return A new GobblinTrackingEvent RecordBuilder */ - public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder(gobblin.metrics.GobblinTrackingEvent other) { + public static org.apache.gobblin.metrics.GobblinTrackingEvent.Builder newBuilder(gobblin.metrics.GobblinTrackingEvent other) { return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder(other); } @@ -244,7 +244,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * @param value The value of 'timestamp'. * @return This builder. */ - public gobblin.metrics.GobblinTrackingEvent.Builder setTimestamp(long value) { + public org.apache.gobblin.metrics.GobblinTrackingEvent.Builder setTimestamp(long value) { validate(fields()[0], value); this.timestamp = value; fieldSetFlags()[0] = true; @@ -266,7 +266,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * Time at which event was created. * @return This builder. */ - public gobblin.metrics.GobblinTrackingEvent.Builder clearTimestamp() { + public org.apache.gobblin.metrics.GobblinTrackingEvent.Builder clearTimestamp() { fieldSetFlags()[0] = false; return this; } @@ -286,7 +286,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * @param value The value of 'namespace'. * @return This builder. */ - public gobblin.metrics.GobblinTrackingEvent.Builder setNamespace(java.lang.String value) { + public org.apache.gobblin.metrics.GobblinTrackingEvent.Builder setNamespace(java.lang.String value) { validate(fields()[1], value); this.namespace = value; fieldSetFlags()[1] = true; @@ -308,7 +308,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * Namespace used for filtering of events. * @return This builder. */ - public gobblin.metrics.GobblinTrackingEvent.Builder clearNamespace() { + public org.apache.gobblin.metrics.GobblinTrackingEvent.Builder clearNamespace() { namespace = null; fieldSetFlags()[1] = false; return this; @@ -329,7 +329,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * @param value The value of 'name'. * @return This builder. */ - public gobblin.metrics.GobblinTrackingEvent.Builder setName(java.lang.String value) { + public org.apache.gobblin.metrics.GobblinTrackingEvent.Builder setName(java.lang.String value) { validate(fields()[2], value); this.name = value; fieldSetFlags()[2] = true; @@ -351,7 +351,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * Event name. * @return This builder. */ - public gobblin.metrics.GobblinTrackingEvent.Builder clearName() { + public org.apache.gobblin.metrics.GobblinTrackingEvent.Builder clearName() { name = null; fieldSetFlags()[2] = false; return this; @@ -372,7 +372,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * @param value The value of 'metadata'. * @return This builder. */ - public gobblin.metrics.GobblinTrackingEvent.Builder setMetadata(java.util.Map<java.lang.String,java.lang.String> value) { + public org.apache.gobblin.metrics.GobblinTrackingEvent.Builder setMetadata(java.util.Map<java.lang.String,java.lang.String> value) { validate(fields()[3], value); this.metadata = value; fieldSetFlags()[3] = true; @@ -394,7 +394,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor * Event metadata. * @return This builder. */ - public gobblin.metrics.GobblinTrackingEvent.Builder clearMetadata() { + public org.apache.gobblin.metrics.GobblinTrackingEvent.Builder clearMetadata() { metadata = null; fieldSetFlags()[3] = false; return this; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/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 fd5618d..76a5230 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 @@ -93,7 +93,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen * Creates a new Metric RecordBuilder. * @return A new Metric RecordBuilder */ - public static gobblin.metrics.Metric.Builder newBuilder() { + public static org.apache.gobblin.metrics.Metric.Builder newBuilder() { return new org.apache.gobblin.metrics.Metric.Builder(); } @@ -102,7 +102,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen * @param other The existing builder to copy. * @return A new Metric RecordBuilder */ - public static gobblin.metrics.Metric.Builder newBuilder(gobblin.metrics.Metric.Builder other) { + public static org.apache.gobblin.metrics.Metric.Builder newBuilder(gobblin.metrics.Metric.Builder other) { return new org.apache.gobblin.metrics.Metric.Builder(other); } @@ -111,7 +111,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen * @param other The existing instance to copy. * @return A new Metric RecordBuilder */ - public static gobblin.metrics.Metric.Builder newBuilder(gobblin.metrics.Metric other) { + public static org.apache.gobblin.metrics.Metric.Builder newBuilder(gobblin.metrics.Metric other) { return new org.apache.gobblin.metrics.Metric.Builder(other); } @@ -178,7 +178,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen * @param value The value of 'name'. * @return This builder. */ - public gobblin.metrics.Metric.Builder setName(java.lang.String value) { + public org.apache.gobblin.metrics.Metric.Builder setName(java.lang.String value) { validate(fields()[0], value); this.name = value; fieldSetFlags()[0] = true; @@ -200,7 +200,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen * Metric name. * @return This builder. */ - public gobblin.metrics.Metric.Builder clearName() { + public org.apache.gobblin.metrics.Metric.Builder clearName() { name = null; fieldSetFlags()[0] = false; return this; @@ -221,7 +221,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen * @param value The value of 'value'. * @return This builder. */ - public gobblin.metrics.Metric.Builder setValue(double value) { + public org.apache.gobblin.metrics.Metric.Builder setValue(double value) { validate(fields()[1], value); this.value = value; fieldSetFlags()[1] = true; @@ -243,7 +243,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase implemen * Metric value. * @return This builder. */ - public gobblin.metrics.Metric.Builder clearValue() { + public org.apache.gobblin.metrics.Metric.Builder clearValue() { fieldSetFlags()[1] = false; return this; } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/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 22bf9b9..c60a200 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 @@ -116,7 +116,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * Creates a new MetricReport RecordBuilder. * @return A new MetricReport RecordBuilder */ - public static gobblin.metrics.MetricReport.Builder newBuilder() { + public static org.apache.gobblin.metrics.MetricReport.Builder newBuilder() { return new org.apache.gobblin.metrics.MetricReport.Builder(); } @@ -125,7 +125,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * @param other The existing builder to copy. * @return A new MetricReport RecordBuilder */ - public static gobblin.metrics.MetricReport.Builder newBuilder(gobblin.metrics.MetricReport.Builder other) { + public static org.apache.gobblin.metrics.MetricReport.Builder newBuilder(gobblin.metrics.MetricReport.Builder other) { return new org.apache.gobblin.metrics.MetricReport.Builder(other); } @@ -134,7 +134,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * @param other The existing instance to copy. * @return A new MetricReport RecordBuilder */ - public static gobblin.metrics.MetricReport.Builder newBuilder(gobblin.metrics.MetricReport other) { + public static org.apache.gobblin.metrics.MetricReport.Builder newBuilder(gobblin.metrics.MetricReport other) { return new org.apache.gobblin.metrics.MetricReport.Builder(other); } @@ -211,7 +211,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * @param value The value of 'tags'. * @return This builder. */ - public gobblin.metrics.MetricReport.Builder setTags(java.util.Map<java.lang.String,java.lang.String> value) { + public org.apache.gobblin.metrics.MetricReport.Builder setTags(java.util.Map<java.lang.String,java.lang.String> value) { validate(fields()[0], value); this.tags = value; fieldSetFlags()[0] = true; @@ -233,7 +233,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * Tags associated with the metrics. * @return This builder. */ - public gobblin.metrics.MetricReport.Builder clearTags() { + public org.apache.gobblin.metrics.MetricReport.Builder clearTags() { tags = null; fieldSetFlags()[0] = false; return this; @@ -254,7 +254,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * @param value The value of 'timestamp'. * @return This builder. */ - public gobblin.metrics.MetricReport.Builder setTimestamp(long value) { + public org.apache.gobblin.metrics.MetricReport.Builder setTimestamp(long value) { validate(fields()[1], value); this.timestamp = value; fieldSetFlags()[1] = true; @@ -276,7 +276,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * Time at which metrics were reported. * @return This builder. */ - public gobblin.metrics.MetricReport.Builder clearTimestamp() { + public org.apache.gobblin.metrics.MetricReport.Builder clearTimestamp() { fieldSetFlags()[1] = false; return this; } @@ -296,7 +296,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * @param value The value of 'metrics'. * @return This builder. */ - public gobblin.metrics.MetricReport.Builder setMetrics(java.util.List<gobblin.metrics.Metric> value) { + public org.apache.gobblin.metrics.MetricReport.Builder setMetrics(java.util.List<gobblin.metrics.Metric> value) { validate(fields()[2], value); this.metrics = value; fieldSetFlags()[2] = true; @@ -318,7 +318,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase im * Array of metrics in this report. * @return This builder. */ - public gobblin.metrics.MetricReport.Builder clearMetrics() { + public org.apache.gobblin.metrics.MetricReport.Builder clearMetrics() { metrics = null; fieldSetFlags()[2] = false; return this; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java b/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java index 4b0a815..e123158 100644 --- a/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java +++ b/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java @@ -406,7 +406,7 @@ public class GobblinMetrics { buildInfluxDBMetricReporter(properties); buildCustomMetricReporters(properties); - // Start reporters that implement gobblin.metrics.report.ScheduledReporter + // Start reporters that implement org.apache.gobblin.metrics.report.ScheduledReporter RootMetricContext.get().startReporting(); // Start reporters that implement com.codahale.metrics.ScheduledReporter @@ -431,7 +431,7 @@ public class GobblinMetrics { this.jmxReporter.get().stop(); } - // Trigger and stop reporters that implement gobblin.metrics.report.ScheduledReporter + // Trigger and stop reporters that implement org.apache.gobblin.metrics.report.ScheduledReporter RootMetricContext.get().stopReporting(); // Trigger and stop reporters that implement com.codahale.metrics.ScheduledReporter http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java index 08e8ca2..df08ed9 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java @@ -57,7 +57,7 @@ import org.apache.gobblin.util.DatasetFilterUtils; /** * A {@link GobblinKafkaConsumerClient} that uses kafka 08 scala consumer client. All the code has been moved from the - * legacy gobblin.source.extractor.extract.kafka.KafkaWrapper's KafkaOldApi + * legacy org.apache.gobblin.source.extractor.extract.kafka.KafkaWrapper's KafkaOldApi */ @Slf4j public class Kafka08ConsumerClient extends AbstractBaseKafkaConsumerClient { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java index 96b0127..35d558e 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java @@ -60,7 +60,7 @@ public class KafkaAvroReporter extends KafkaReporter { /** * A static factory class for obtaining new {@link org.apache.gobblin.metrics.kafka.KafkaAvroReporter.Builder}s * - * @see gobblin.metrics.kafka.KafkaAvroReporter.Builder + * @see org.apache.gobblin.metrics.kafka.KafkaAvroReporter.Builder */ public static class BuilderFactory { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java index 4c6abe4..2aa0e97 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java @@ -84,7 +84,7 @@ public class KafkaReporter extends MetricReportReporter { /** * A static factory class for obtaining new {@link org.apache.gobblin.metrics.kafka.KafkaReporter.Builder}s * - * @see gobblin.metrics.kafka.KafkaReporter.Builder + * @see org.apache.gobblin.metrics.kafka.KafkaReporter.Builder */ public static class BuilderFactory { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java index d038cdf..3527431 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java @@ -67,7 +67,7 @@ public class GraphiteReporter extends ConfiguredScheduledReporter { /** * A static factory class for obtaining new {@link org.apache.gobblin.metrics.graphite.GraphiteReporter.Builder}s * - * @see gobblin.metrics.graphite.GraphiteReporter.Builder + * @see org.apache.gobblin.metrics.graphite.GraphiteReporter.Builder */ public static class Factory { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java index 952b16f..0bd29b7 100644 --- a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java +++ b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java @@ -74,7 +74,7 @@ public class InfluxDBReporter extends ConfiguredScheduledReporter { /** * A static factory class for obtaining new {@link org.apache.gobblin.metrics.influxdb.InfluxDBReporter.Builder}s * - * @see gobblin.metrics.influxdb.InfluxDBReporter.Builder + * @see org.apache.gobblin.metrics.influxdb.InfluxDBReporter.Builder */ public static class Factory { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java index 1bfd7b3..d3ca9f9 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java @@ -75,7 +75,7 @@ public class AvroToJdbcEntryConverterInitializer implements ConverterInitializer * retrieve it and store it into WorkUnit so that AvroToJdbcEntryConverter will use it later. * * {@inheritDoc} - * @see gobblin.initializer.Initializer#initialize() + * @see org.apache.gobblin.initializer.Initializer#initialize() */ @Override public void initialize() { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java index 3677874..080cc69 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java @@ -108,7 +108,7 @@ public class AvroToJdbcEntryConverter extends Converter<Schema, JdbcEntrySchema, * Fetches JdbcWriterCommands. * Builds field name mapping between Avro and JDBC. * {@inheritDoc} - * @see gobblin.converter.Converter#init(gobblin.configuration.WorkUnitState) + * @see org.apache.gobblin.converter.Converter#init(gobblin.configuration.WorkUnitState) */ @Override public Converter<Schema, JdbcEntrySchema, GenericRecord, JdbcEntryData> init(WorkUnitState workUnit) { @@ -162,7 +162,7 @@ public class AvroToJdbcEntryConverter extends Converter<Schema, JdbcEntrySchema, * 7. Conversion assumes that both schema, Avro and JDBC, uses same column name where name space in Avro is ignored. * For case sensitivity, Avro is case sensitive where it differs in JDBC based on underlying database. As Avro is case sensitive, column name equality also take case sensitive in to account. * - * @see gobblin.converter.Converter#convertSchema(java.lang.Object, gobblin.configuration.WorkUnitState) + * @see org.apache.gobblin.converter.Converter#convertSchema(java.lang.Object, org.apache.gobblin.configuration.WorkUnitState) */ @Override public JdbcEntrySchema convertSchema(Schema inputSchema, WorkUnitState workUnit) throws SchemaConversionException { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java index 4503db3..4561bb6 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java @@ -129,7 +129,7 @@ public class JdbcPublisher extends DataPublisher { * so that copying table threads wait until transaction lock times out and throwing exception(MySQL). Is there a way to avoid this? * * {@inheritDoc} - * @see gobblin.publisher.DataPublisher#publishData(java.util.Collection) + * @see org.apache.gobblin.publisher.DataPublisher#publishData(java.util.Collection) */ @Override public void publishData(Collection<? extends WorkUnitState> states) throws IOException { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java index b3b6ac2..e893ef4 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java @@ -294,7 +294,7 @@ public class OracleExtractor extends JdbcExtractor { * up to second and Oracle extractor will keep the same behavior. * * {@inheritDoc} - * @see gobblin.source.extractor.extract.ProtocolSpecificLayer#getTimestampPredicateCondition(java.lang.String, long, java.lang.String, java.lang.String) + * @see org.apache.gobblin.source.extractor.extract.ProtocolSpecificLayer#getTimestampPredicateCondition(java.lang.String, long, java.lang.String, java.lang.String) */ @Override public String getTimestampPredicateCondition(String column, long value, String valueFormat, String operator) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java index 5fc2ef6..b98f52f 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java @@ -121,7 +121,7 @@ public class JdbcWriter implements DataWriter<JdbcEntryData> { /** * Invokes JdbcWriterCommands.insert * {@inheritDoc} - * @see gobblin.writer.DataWriter#write(java.lang.Object) + * @see org.apache.gobblin.writer.DataWriter#write(java.lang.Object) */ @Override public void write(JdbcEntryData record) throws IOException { @@ -140,7 +140,7 @@ public class JdbcWriter implements DataWriter<JdbcEntryData> { /** * Flushes JdbcWriterCommands and commit. * {@inheritDoc} - * @see gobblin.writer.DataWriter#commit() + * @see org.apache.gobblin.writer.DataWriter#commit() */ @Override public void commit() throws IOException { @@ -158,7 +158,7 @@ public class JdbcWriter implements DataWriter<JdbcEntryData> { /** * Staging table is needed by publisher and won't be cleaned here. * {@inheritDoc} - * @see gobblin.writer.DataWriter#cleanup() + * @see org.apache.gobblin.writer.DataWriter#cleanup() */ @Override public void cleanup() throws IOException {} @@ -193,7 +193,7 @@ public class JdbcWriter implements DataWriter<JdbcEntryData> { /** * This is not supported for JDBC writer. * {@inheritDoc} - * @see gobblin.writer.DataWriter#bytesWritten() + * @see org.apache.gobblin.writer.DataWriter#bytesWritten() */ @Override public long bytesWritten() throws IOException { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java index cd791d5..82fb4ad 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java @@ -106,7 +106,7 @@ public abstract class BaseJdbcBufferedInserter implements JdbcBufferedInserter { * </p> * * {@inheritDoc} - * @see gobblin.writer.commands.JdbcBufferedInserter#insert(java.lang.String, java.lang.String, gobblin.converter.jdbc.JdbcEntryData) + * @see org.apache.gobblin.writer.commands.JdbcBufferedInserter#insert(java.lang.String, java.lang.String, org.apache.gobblin.converter.jdbc.JdbcEntryData) */ @Override public void insert(String databaseName, String table, JdbcEntryData jdbcEntryData) throws SQLException { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java index 7009256..5a5cf81 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlWriterCommands.java @@ -113,7 +113,7 @@ public class MySqlWriterCommands implements JdbcWriterCommands { /** * https://dev.mysql.com/doc/connector-j/en/connector-j-reference-type-conversions.html * {@inheritDoc} - * @see gobblin.writer.commands.JdbcWriterCommands#retrieveDateColumns(java.sql.Connection, java.lang.String) + * @see org.apache.gobblin.writer.commands.JdbcWriterCommands#retrieveDateColumns(java.sql.Connection, java.lang.String) */ @Override public Map<String, JdbcType> retrieveDateColumns(String database, String table) throws SQLException { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java index 39212e9..7891193 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/TeradataWriterCommands.java @@ -133,7 +133,7 @@ public class TeradataWriterCommands implements JdbcWriterCommands { /** * {@inheritDoc} - * @see gobblin.writer.commands.JdbcWriterCommands#retrieveDateColumns(java.sql.Connection, java.lang.String) + * @see org.apache.gobblin.writer.commands.JdbcWriterCommands#retrieveDateColumns(java.sql.Connection, java.lang.String) */ @Override public Map<String, JdbcType> retrieveDateColumns(String database, String table) throws SQLException { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java index a293349..bdaf1e1 100644 --- a/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java +++ b/gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java @@ -95,7 +95,7 @@ public class JdbcWriterInitializer implements WriterInitializer { * Drop table if it's created by this instance. * Truncate staging tables passed by user. * {@inheritDoc} - * @see gobblin.Initializer#close() + * @see org.apache.gobblin.Initializer#close() */ @Override public void close() { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java index d12a19a..c23f1ff 100644 --- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java +++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java @@ -92,7 +92,7 @@ public class GoogleDriveFsHelper implements TimestampAwareFileBasedHelper { * List files under folder ID recursively. Folder won't be included in the result. If there's no files under folder ID, it returns empty list. * If folder ID is not defined, it will provide files under root directory. * {@inheritDoc} - * @see gobblin.source.extractor.filebased.FileBasedHelper#ls(java.lang.String) + * @see org.apache.gobblin.source.extractor.filebased.FileBasedHelper#ls(java.lang.String) */ @Override public List<String> ls(String folderId) throws FileBasedHelperException { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java index b34a485..00e6be8 100644 --- a/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java +++ b/gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveSource.java @@ -51,7 +51,7 @@ public class GoogleDriveSource<S, D> extends FileBasedSource<S, D> { /** * As Google Drive extractor needs file system helper, it invokes to initialize file system helper. * {@inheritDoc} - * @see gobblin.source.Source#getExtractor(gobblin.configuration.WorkUnitState) + * @see org.apache.gobblin.source.Source#getExtractor(gobblin.configuration.WorkUnitState) */ @Override public Extractor<S, D> getExtractor(WorkUnitState state) throws IOException { @@ -72,7 +72,7 @@ public class GoogleDriveSource<S, D> extends FileBasedSource<S, D> { /** * Initialize file system helper at most once for this instance. * {@inheritDoc} - * @see gobblin.source.extractor.filebased.FileBasedSource#initFileSystemHelper(gobblin.configuration.State) + * @see org.apache.gobblin.source.extractor.filebased.FileBasedSource#initFileSystemHelper(gobblin.configuration.State) */ @Override public synchronized void initFileSystemHelper(State state) throws FileBasedHelperException { @@ -99,7 +99,7 @@ public class GoogleDriveSource<S, D> extends FileBasedSource<S, D> { * missing file ID represents all files will be included on current and subfolder. * * {@inheritDoc} - * @see gobblin.source.extractor.filebased.FileBasedSource#getcurrentFsSnapshot(gobblin.configuration.State) + * @see org.apache.gobblin.source.extractor.filebased.FileBasedSource#getcurrentFsSnapshot(gobblin.configuration.State) */ @Override public List<String> getcurrentFsSnapshot(State state) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json ---------------------------------------------------------------------- diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json b/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json index 40e5004..a63ca5a 100644 --- a/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json +++ b/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json @@ -3,7 +3,7 @@ "namespace" : "org.apache.gobblin.rest", "path" : "/jobExecutions", "schema" : "org.apache.gobblin.rest.JobExecutionQueryResult", - "doc" : "A Rest.li resource for serving queries of Gobblin job executions.\n\ngenerated from: gobblin.rest.JobExecutionInfoResource", + "doc" : "A Rest.li resource for serving queries of Gobblin job executions.\n\ngenerated from: org.apache.gobblin.rest.JobExecutionInfoResource", "collection" : { "identifier" : { "name" : "jobExecutionsId", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json ---------------------------------------------------------------------- diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json b/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json index 50b37b5..4f6a7e3 100644 --- a/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json +++ b/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json @@ -329,7 +329,7 @@ "namespace" : "org.apache.gobblin.rest", "path" : "/jobExecutions", "schema" : "org.apache.gobblin.rest.JobExecutionQueryResult", - "doc" : "A Rest.li resource for serving queries of Gobblin job executions.\n\ngenerated from: gobblin.rest.JobExecutionInfoResource", + "doc" : "A Rest.li resource for serving queries of Gobblin job executions.\n\ngenerated from: org.apache.gobblin.rest.JobExecutionInfoResource", "collection" : { "identifier" : { "name" : "jobExecutionsId", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json index 3f06bbe..68c990c 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json @@ -3,7 +3,7 @@ "namespace" : "org.apache.gobblin.service", "path" : "/flowconfigs", "schema" : "org.apache.gobblin.service.FlowConfig", - "doc" : "Resource for handling flow configuration requests\n\ngenerated from: gobblin.service.FlowConfigsResource", + "doc" : "Resource for handling flow configuration requests\n\ngenerated from: org.apache.gobblin.service.FlowConfigsResource", "collection" : { "identifier" : { "name" : "id", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json index a8e4d1c..7810aa9 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json @@ -3,7 +3,7 @@ "namespace" : "org.apache.gobblin.service", "path" : "/flowstatuses", "schema" : "org.apache.gobblin.service.FlowStatus", - "doc" : "Resource for handling flow status requests\n\ngenerated from: gobblin.service.FlowStatusResource", + "doc" : "Resource for handling flow status requests\n\ngenerated from: org.apache.gobblin.service.FlowStatusResource", "collection" : { "identifier" : { "name" : "id", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json index 5871f21..6106b7a 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json @@ -87,7 +87,7 @@ "namespace" : "org.apache.gobblin.service", "path" : "/flowconfigs", "schema" : "org.apache.gobblin.service.FlowConfig", - "doc" : "Resource for handling flow configuration requests\n\ngenerated from: gobblin.service.FlowConfigsResource", + "doc" : "Resource for handling flow configuration requests\n\ngenerated from: org.apache.gobblin.service.FlowConfigsResource", "collection" : { "identifier" : { "name" : "id", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json index cd2943d..99b6a1f 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json @@ -200,7 +200,7 @@ "namespace" : "org.apache.gobblin.service", "path" : "/flowstatuses", "schema" : "org.apache.gobblin.service.FlowStatus", - "doc" : "Resource for handling flow status requests\n\ngenerated from: gobblin.service.FlowStatusResource", + "doc" : "Resource for handling flow status requests\n\ngenerated from: org.apache.gobblin.service.FlowStatusResource", "collection" : { "identifier" : { "name" : "id", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java index 2d48972..11bd64a 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/java/org/apache/gobblin/service/FlowStatusTest.java @@ -94,11 +94,11 @@ public class FlowStatusTest { */ @Test public void testFindLatest() throws Exception { - gobblin.service.monitoring.JobStatus js1 = gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") + org.apache.gobblin.service.monitoring.JobStatus js1 = org.apache.gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") .flowName("flow1").jobGroup("jgroup1").jobName("job1").startTime(1000L).endTime(5000L) .eventName(TimingEvent.LauncherTimings.JOB_COMPLETE).flowExecutionId(0).message("Test message 1") .processedCount(100).jobExecutionId(1).lowWatermark("watermark:1").highWatermark("watermark:2").build(); - gobblin.service.monitoring.JobStatus js2 = gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") + org.apache.gobblin.service.monitoring.JobStatus js2 = org.apache.gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") .flowName("flow1").jobGroup("jgroup1").jobName("job1").startTime(2000L).endTime(6000L) .eventName(TimingEvent.LauncherTimings.JOB_COMPLETE).flowExecutionId(1).message("Test message 2") .processedCount(200).jobExecutionId(2).lowWatermark("watermark:2").highWatermark("watermark:3").build(); @@ -123,7 +123,7 @@ public class FlowStatusTest { Assert.assertEquals(jobStatusList2.size(), jobStatuses.size()); for (int i = 0; i < jobStatuses.size(); i++) { - gobblin.service.monitoring.JobStatus mjs = jobStatusList2.get(i); + org.apache.gobblin.service.monitoring.JobStatus mjs = jobStatusList2.get(i); JobStatus js = jobStatuses.get(i); compareJobStatus(js, mjs); @@ -136,11 +136,11 @@ public class FlowStatusTest { */ @Test public void testGetCompleted() throws Exception { - gobblin.service.monitoring.JobStatus js1 = gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") + org.apache.gobblin.service.monitoring.JobStatus js1 = org.apache.gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") .flowName("flow1").jobGroup("jgroup1").jobName("job1").startTime(1000L).endTime(5000L) .eventName(TimingEvent.LauncherTimings.JOB_COMPLETE).flowExecutionId(0).message("Test message 1") .processedCount(100).jobExecutionId(1).lowWatermark("watermark:1").highWatermark("watermark:2").build(); - gobblin.service.monitoring.JobStatus js2 = gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") + org.apache.gobblin.service.monitoring.JobStatus js2 = org.apache.gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") .flowName("flow1").jobGroup("jgroup1").jobName("job2").startTime(2000L).endTime(6000L) .eventName(TimingEvent.LauncherTimings.JOB_COMPLETE).flowExecutionId(0).message("Test message 2") .processedCount(200).jobExecutionId(2).lowWatermark("watermark:2").highWatermark("watermark:3").build(); @@ -163,7 +163,7 @@ public class FlowStatusTest { Assert.assertEquals(jobStatusList.size(), jobStatuses.size()); for (int i = 0; i < jobStatuses.size(); i++) { - gobblin.service.monitoring.JobStatus mjs = jobStatusList.get(i); + org.apache.gobblin.service.monitoring.JobStatus mjs = jobStatusList.get(i); JobStatus js = jobStatuses.get(i); compareJobStatus(js, mjs); @@ -176,11 +176,11 @@ public class FlowStatusTest { */ @Test public void testGetRunning() throws Exception { - gobblin.service.monitoring.JobStatus js1 = gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") + org.apache.gobblin.service.monitoring.JobStatus js1 = org.apache.gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") .flowName("flow1").jobGroup("jgroup1").jobName("job1").startTime(1000L).endTime(5000L) .eventName(TimingEvent.LauncherTimings.JOB_RUN).flowExecutionId(0).message("Test message 1").processedCount(100) .jobExecutionId(1).lowWatermark("watermark:1").highWatermark("watermark:2").build(); - gobblin.service.monitoring.JobStatus js2 = gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") + org.apache.gobblin.service.monitoring.JobStatus js2 = org.apache.gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") .flowName("flow1").jobGroup("jgroup1").jobName("job2").startTime(2000L).endTime(6000L) .eventName(TimingEvent.LauncherTimings.JOB_COMPLETE).flowExecutionId(0).message("Test message 2") .processedCount(200).jobExecutionId(2).lowWatermark("watermark:2").highWatermark("watermark:3").build(); @@ -203,7 +203,7 @@ public class FlowStatusTest { Assert.assertEquals(jobStatusList.size(), jobStatuses.size()); for (int i = 0; i < jobStatuses.size(); i++) { - gobblin.service.monitoring.JobStatus mjs = jobStatusList.get(i); + org.apache.gobblin.service.monitoring.JobStatus mjs = jobStatusList.get(i); JobStatus js = jobStatuses.get(i); compareJobStatus(js, mjs); @@ -216,11 +216,11 @@ public class FlowStatusTest { */ @Test public void testGetFailed() throws Exception { - gobblin.service.monitoring.JobStatus js1 = gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") + org.apache.gobblin.service.monitoring.JobStatus js1 = org.apache.gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") .flowName("flow1").jobGroup("jgroup1").jobName("job1").startTime(1000L).endTime(5000L) .eventName(TimingEvent.LauncherTimings.JOB_COMPLETE).flowExecutionId(0).message("Test message 1") .processedCount(100).jobExecutionId(1).lowWatermark("watermark:1").highWatermark("watermark:2").build(); - gobblin.service.monitoring.JobStatus js2 = gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") + org.apache.gobblin.service.monitoring.JobStatus js2 = org.apache.gobblin.service.monitoring.JobStatus.builder().flowGroup("fgroup1") .flowName("flow1").jobGroup("jgroup1").jobName("job2").startTime(2000L).endTime(6000L) .eventName(TimingEvent.LauncherTimings.JOB_FAILED).flowExecutionId(0).message("Test message 2") .processedCount(200).jobExecutionId(2).lowWatermark("watermark:2").highWatermark("watermark:3").build(); @@ -243,7 +243,7 @@ public class FlowStatusTest { Assert.assertEquals(jobStatusList.size(), jobStatuses.size()); for (int i = 0; i < jobStatuses.size(); i++) { - gobblin.service.monitoring.JobStatus mjs = jobStatusList.get(i); + org.apache.gobblin.service.monitoring.JobStatus mjs = jobStatusList.get(i); JobStatus js = jobStatuses.get(i); compareJobStatus(js, mjs); @@ -266,7 +266,7 @@ public class FlowStatusTest { * @param js JobStatus from REST * @param mjs JobStatus from monitoring */ - private void compareJobStatus(JobStatus js, gobblin.service.monitoring.JobStatus mjs) { + private void compareJobStatus(JobStatus js, org.apache.gobblin.service.monitoring.JobStatus mjs) { Assert.assertEquals(mjs.getFlowGroup(), js.getFlowId().getFlowGroup()); Assert.assertEquals(mjs.getFlowName(), js.getFlowId().getFlowName()); Assert.assertEquals(mjs.getJobGroup(), js.getJobId().getJobGroup()); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java index 62d3737..d4b2ced 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java @@ -66,7 +66,7 @@ public class FlowStatusResource extends ComplexKeyResourceTemplate<FlowStatusId, LOG.info("Get called with flowGroup " + flowGroup + " flowName " + flowName + " flowExecutionId " + flowExecutionId); - gobblin.service.monitoring.FlowStatus flowStatus = + org.apache.gobblin.service.monitoring.FlowStatus flowStatus = _flowStatusGenerator.getFlowStatus(flowName, flowGroup, flowExecutionId); // this returns null to raise a 404 error if flowStatus is null @@ -78,7 +78,7 @@ public class FlowStatusResource extends ComplexKeyResourceTemplate<FlowStatusId, @QueryParam("flowId") FlowId flowId) { LOG.info("getLatestFlowStatus called with flowGroup " + flowId.getFlowGroup() + " flowName " + flowId.getFlowName()); - gobblin.service.monitoring.FlowStatus latestFlowStatus = + org.apache.gobblin.service.monitoring.FlowStatus latestFlowStatus = _flowStatusGenerator.getLatestFlowStatus(flowId.getFlowName(), flowId.getFlowGroup()); if (latestFlowStatus != null) { @@ -110,7 +110,7 @@ public class FlowStatusResource extends ComplexKeyResourceTemplate<FlowStatusId, StringBuffer flowMessagesStringBuffer = new StringBuffer(); while (jobStatusIter.hasNext()) { - gobblin.service.monitoring.JobStatus queriedJobStatus = jobStatusIter.next(); + org.apache.gobblin.service.monitoring.JobStatus queriedJobStatus = jobStatusIter.next(); JobStatus jobStatus = new JobStatus(); jobStatus.setFlowId(flowId) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json index 4cb7820..b4415f0 100644 --- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json +++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json @@ -3,7 +3,7 @@ "namespace" : "org.apache.gobblin.restli.throttling", "path" : "/permits", "schema" : "org.apache.gobblin.restli.throttling.PermitAllocation", - "doc" : "Restli resource for allocating permits through Rest calls. Simply calls a {@link Limiter} in the server configured\n through {@link SharedResourcesBroker}.\n\ngenerated from: gobblin.restli.throttling.LimiterServerResource", + "doc" : "Restli resource for allocating permits through Rest calls. Simply calls a {@link Limiter} in the server configured\n through {@link SharedResourcesBroker}.\n\ngenerated from: org.apache.gobblin.restli.throttling.LimiterServerResource", "collection" : { "identifier" : { "name" : "permitsId", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json index c534de20e8..90fdd8d 100644 --- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json +++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json @@ -56,7 +56,7 @@ "namespace" : "org.apache.gobblin.restli.throttling", "path" : "/permits", "schema" : "org.apache.gobblin.restli.throttling.PermitAllocation", - "doc" : "Restli resource for allocating permits through Rest calls. Simply calls a {@link Limiter} in the server configured\n through {@link SharedResourcesBroker}.\n\ngenerated from: gobblin.restli.throttling.LimiterServerResource", + "doc" : "Restli resource for allocating permits through Rest calls. Simply calls a {@link Limiter} in the server configured\n through {@link SharedResourcesBroker}.\n\ngenerated from: org.apache.gobblin.restli.throttling.LimiterServerResource", "collection" : { "identifier" : { "name" : "permitsId", http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/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 939f251..bbd5c05 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 org.apache.gobblin.configuration.State(sysConfig.getConfigAsProperties()); + org.apache.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/d932e431/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 1daffaf..193e53d 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 @@ -348,7 +348,7 @@ public class StandardGobblinInstanceDriver extends DefaultGobblinInstanceDriverI } public MetricContext getDefaultMetricContext() { - gobblin.configuration.State fakeState = + org.apache.gobblin.configuration.State fakeState = new org.apache.gobblin.configuration.State(getSysConfig().getConfigAsProperties()); List<Tag<?>> tags = new ArrayList<>(); tags.add(new Tag<>(StandardMetrics.INSTANCE_NAME_TAG, getInstanceName())); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d932e431/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 a4efcdd..c2259ee 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 @@ -223,7 +223,7 @@ public class StandardGobblinInstanceLauncher extends AbstractIdleService } private MetricContext getDefaultMetricContext() { - gobblin.configuration.State fakeState = + org.apache.gobblin.configuration.State fakeState = 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/d932e431/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 c126ab2..33bd7db 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 @@ -434,7 +434,7 @@ public class JobLauncherExecutionDriver extends FutureTask<JobExecutionResult> i return _gobblinEnv.get().getMetricContext() .childBuilder(JobExecutionLauncher.class.getSimpleName()).build(); } - gobblin.configuration.State fakeState = + org.apache.gobblin.configuration.State fakeState = new org.apache.gobblin.configuration.State(getSysConfig().getConfigAsProperties()); List<Tag<?>> tags = new ArrayList<>(); MetricContext res = Instrumented.getMetricContext(fakeState, Launcher.class, tags);
