You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:53:24 UTC
[66/77] [abbrv] incubator-gobblin git commit: Update package from
gobblin to org.apache.gobblin for typed references
Update package from gobblin to org.apache.gobblin for typed references
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/588f72db
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/588f72db
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/588f72db
Branch: refs/heads/master
Commit: 588f72db4bd55839a1e0fe58ff02eaa84b39e10f
Parents: 81a66cd
Author: Abhishek Tiwari <ab...@gmail.com>
Authored: Sun Jul 30 20:21:46 2017 -0700
Committer: Abhishek Tiwari <ab...@gmail.com>
Committed: Sun Jul 30 20:21:46 2017 -0700
----------------------------------------------------------------------
.../version/TimestampedDatasetVersion.java | 2 +-
.../src/main/gen-java/FlatGobblinMetric.java | 432 ------------------
.../src/main/gen-java/GobblinTrackingEvent.java | 433 -------------------
.../src/main/gen-java/Metric.java | 279 ------------
.../src/main/gen-java/MetricReport.java | 356 ---------------
.../apache/gobblin/service/FlowStatusTest.java | 14 +-
.../gobblin/service/FlowStatusResource.java | 2 +-
7 files changed, 9 insertions(+), 1509 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/588f72db/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java
index cbe4c30..ee8d380 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java
@@ -50,7 +50,7 @@ public class TimestampedDatasetVersion extends org.apache.gobblin.data.managemen
}
public static Collection<TimestampedDatasetVersion> convertFromGeneralVersion(
- Collection<gobblin.data.management.version.TimestampedDatasetVersion> realVersions) {
+ Collection<org.apache.gobblin.data.management.version.TimestampedDatasetVersion> realVersions) {
List<TimestampedDatasetVersion> timestampedVersions = Lists.newArrayList();
for (org.apache.gobblin.data.management.version.TimestampedDatasetVersion realVersion : realVersions) {
timestampedVersions.add(new TimestampedDatasetVersion(realVersion));
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/588f72db/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/FlatGobblinMetric.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/FlatGobblinMetric.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/FlatGobblinMetric.java
deleted file mode 100644
index 1deb457..0000000
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/FlatGobblinMetric.java
+++ /dev/null
@@ -1,432 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-
-import org.apache.avro.specific.SpecificData;
-
-@SuppressWarnings("all")
-@org.apache.avro.specific.AvroGenerated
-public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- private static final long serialVersionUID = -3004215093744611038L;
- public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"FlatGobblinMetric\",\"fields\":[{\"name\":\"tags\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},\"doc\":\"Tags associated with the metrics in the form key:value.\"},{\"name\":\"timestamp\",\"type\":\"long\",\"doc\":\"Time at which metrics were reported.\"},{\"name\":\"metricName\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"},\"doc\":\"The name of this metric.\"},{\"name\":\"metricValue\",\"type\":\"double\",\"doc\":\"The value of this metric.\"}],\"namespace\":\"org.apache.gobblin.metrics\"}");
- public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; }
- /** Tags associated with the metrics in the form key:value. */
- @Deprecated public java.util.List<java.lang.String> tags;
- /** Time at which metrics were reported. */
- @Deprecated public long timestamp;
- /** The name of this metric. */
- @Deprecated public java.lang.String metricName;
- /** The value of this metric. */
- @Deprecated public double metricValue;
-
- /**
- * Default constructor. Note that this does not initialize fields
- * to their default values from the schema. If that is desired then
- * one should use <code>newBuilder()</code>.
- */
- public FlatGobblinMetric() {}
-
- /**
- * All-args constructor.
- * @param tags Tags associated with the metrics in the form key:value.
- * @param timestamp Time at which metrics were reported.
- * @param metricName The name of this metric.
- * @param metricValue The value of this metric.
- */
- public FlatGobblinMetric(java.util.List<java.lang.String> tags, java.lang.Long timestamp, java.lang.String metricName, java.lang.Double metricValue) {
- this.tags = tags;
- this.timestamp = timestamp;
- this.metricName = metricName;
- this.metricValue = metricValue;
- }
-
- public org.apache.avro.Schema getSchema() { return SCHEMA$; }
- // Used by DatumWriter. Applications should not call.
- public java.lang.Object get(int field$) {
- switch (field$) {
- case 0: return tags;
- case 1: return timestamp;
- case 2: return metricName;
- case 3: return metricValue;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-
- // Used by DatumReader. Applications should not call.
- @SuppressWarnings(value="unchecked")
- public void put(int field$, java.lang.Object value$) {
- switch (field$) {
- case 0: tags = (java.util.List<java.lang.String>)value$; break;
- case 1: timestamp = (java.lang.Long)value$; break;
- case 2: metricName = (java.lang.String)value$; break;
- case 3: metricValue = (java.lang.Double)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-
- /**
- * Gets the value of the 'tags' field.
- * @return Tags associated with the metrics in the form key:value.
- */
- public java.util.List<java.lang.String> getTags() {
- return tags;
- }
-
- /**
- * Sets the value of the 'tags' field.
- * Tags associated with the metrics in the form key:value.
- * @param value the value to set.
- */
- public void setTags(java.util.List<java.lang.String> value) {
- this.tags = value;
- }
-
- /**
- * Gets the value of the 'timestamp' field.
- * @return Time at which metrics were reported.
- */
- public java.lang.Long getTimestamp() {
- return timestamp;
- }
-
- /**
- * Sets the value of the 'timestamp' field.
- * Time at which metrics were reported.
- * @param value the value to set.
- */
- public void setTimestamp(java.lang.Long value) {
- this.timestamp = value;
- }
-
- /**
- * Gets the value of the 'metricName' field.
- * @return The name of this metric.
- */
- public java.lang.String getMetricName() {
- return metricName;
- }
-
- /**
- * Sets the value of the 'metricName' field.
- * The name of this metric.
- * @param value the value to set.
- */
- public void setMetricName(java.lang.String value) {
- this.metricName = value;
- }
-
- /**
- * Gets the value of the 'metricValue' field.
- * @return The value of this metric.
- */
- public java.lang.Double getMetricValue() {
- return metricValue;
- }
-
- /**
- * Sets the value of the 'metricValue' field.
- * The value of this metric.
- * @param value the value to set.
- */
- public void setMetricValue(java.lang.Double value) {
- this.metricValue = value;
- }
-
- /**
- * Creates a new FlatGobblinMetric RecordBuilder.
- * @return A new FlatGobblinMetric RecordBuilder
- */
- public static FlatGobblinMetric.Builder newBuilder() {
- return new FlatGobblinMetric.Builder();
- }
-
- /**
- * Creates a new FlatGobblinMetric RecordBuilder by copying an existing Builder.
- * @param other The existing builder to copy.
- * @return A new FlatGobblinMetric RecordBuilder
- */
- public static FlatGobblinMetric.Builder newBuilder(FlatGobblinMetric.Builder other) {
- return new FlatGobblinMetric.Builder(other);
- }
-
- /**
- * Creates a new FlatGobblinMetric RecordBuilder by copying an existing FlatGobblinMetric instance.
- * @param other The existing instance to copy.
- * @return A new FlatGobblinMetric RecordBuilder
- */
- public static FlatGobblinMetric.Builder newBuilder(FlatGobblinMetric other) {
- return new FlatGobblinMetric.Builder(other);
- }
-
- /**
- * RecordBuilder for FlatGobblinMetric instances.
- */
- public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<FlatGobblinMetric>
- implements org.apache.avro.data.RecordBuilder<FlatGobblinMetric> {
-
- /** Tags associated with the metrics in the form key:value. */
- private java.util.List<java.lang.String> tags;
- /** Time at which metrics were reported. */
- private long timestamp;
- /** The name of this metric. */
- private java.lang.String metricName;
- /** The value of this metric. */
- private double metricValue;
-
- /** Creates a new Builder */
- private Builder() {
- super(SCHEMA$);
- }
-
- /**
- * Creates a Builder by copying an existing Builder.
- * @param other The existing Builder to copy.
- */
- private Builder(FlatGobblinMetric.Builder other) {
- super(other);
- if (isValidValue(fields()[0], other.tags)) {
- this.tags = data().deepCopy(fields()[0].schema(), other.tags);
- fieldSetFlags()[0] = true;
- }
- if (isValidValue(fields()[1], other.timestamp)) {
- this.timestamp = data().deepCopy(fields()[1].schema(), other.timestamp);
- fieldSetFlags()[1] = true;
- }
- if (isValidValue(fields()[2], other.metricName)) {
- this.metricName = data().deepCopy(fields()[2].schema(), other.metricName);
- fieldSetFlags()[2] = true;
- }
- if (isValidValue(fields()[3], other.metricValue)) {
- this.metricValue = data().deepCopy(fields()[3].schema(), other.metricValue);
- fieldSetFlags()[3] = true;
- }
- }
-
- /**
- * Creates a Builder by copying an existing FlatGobblinMetric instance
- * @param other The existing instance to copy.
- */
- private Builder(FlatGobblinMetric other) {
- super(SCHEMA$);
- if (isValidValue(fields()[0], other.tags)) {
- this.tags = data().deepCopy(fields()[0].schema(), other.tags);
- fieldSetFlags()[0] = true;
- }
- if (isValidValue(fields()[1], other.timestamp)) {
- this.timestamp = data().deepCopy(fields()[1].schema(), other.timestamp);
- fieldSetFlags()[1] = true;
- }
- if (isValidValue(fields()[2], other.metricName)) {
- this.metricName = data().deepCopy(fields()[2].schema(), other.metricName);
- fieldSetFlags()[2] = true;
- }
- if (isValidValue(fields()[3], other.metricValue)) {
- this.metricValue = data().deepCopy(fields()[3].schema(), other.metricValue);
- fieldSetFlags()[3] = true;
- }
- }
-
- /**
- * Gets the value of the 'tags' field.
- * Tags associated with the metrics in the form key:value.
- * @return The value.
- */
- public java.util.List<java.lang.String> getTags() {
- return tags;
- }
-
- /**
- * Sets the value of the 'tags' field.
- * Tags associated with the metrics in the form key:value.
- * @param value The value of 'tags'.
- * @return This builder.
- */
- public FlatGobblinMetric.Builder setTags(java.util.List<java.lang.String> value) {
- validate(fields()[0], value);
- this.tags = value;
- fieldSetFlags()[0] = true;
- return this;
- }
-
- /**
- * Checks whether the 'tags' field has been set.
- * Tags associated with the metrics in the form key:value.
- * @return True if the 'tags' field has been set, false otherwise.
- */
- public boolean hasTags() {
- return fieldSetFlags()[0];
- }
-
-
- /**
- * Clears the value of the 'tags' field.
- * Tags associated with the metrics in the form key:value.
- * @return This builder.
- */
- public FlatGobblinMetric.Builder clearTags() {
- tags = null;
- fieldSetFlags()[0] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'timestamp' field.
- * Time at which metrics were reported.
- * @return The value.
- */
- public java.lang.Long getTimestamp() {
- return timestamp;
- }
-
- /**
- * Sets the value of the 'timestamp' field.
- * Time at which metrics were reported.
- * @param value The value of 'timestamp'.
- * @return This builder.
- */
- public FlatGobblinMetric.Builder setTimestamp(long value) {
- validate(fields()[1], value);
- this.timestamp = value;
- fieldSetFlags()[1] = true;
- return this;
- }
-
- /**
- * Checks whether the 'timestamp' field has been set.
- * Time at which metrics were reported.
- * @return True if the 'timestamp' field has been set, false otherwise.
- */
- public boolean hasTimestamp() {
- return fieldSetFlags()[1];
- }
-
-
- /**
- * Clears the value of the 'timestamp' field.
- * Time at which metrics were reported.
- * @return This builder.
- */
- public FlatGobblinMetric.Builder clearTimestamp() {
- fieldSetFlags()[1] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'metricName' field.
- * The name of this metric.
- * @return The value.
- */
- public java.lang.String getMetricName() {
- return metricName;
- }
-
- /**
- * Sets the value of the 'metricName' field.
- * The name of this metric.
- * @param value The value of 'metricName'.
- * @return This builder.
- */
- public FlatGobblinMetric.Builder setMetricName(java.lang.String value) {
- validate(fields()[2], value);
- this.metricName = value;
- fieldSetFlags()[2] = true;
- return this;
- }
-
- /**
- * Checks whether the 'metricName' field has been set.
- * The name of this metric.
- * @return True if the 'metricName' field has been set, false otherwise.
- */
- public boolean hasMetricName() {
- return fieldSetFlags()[2];
- }
-
-
- /**
- * Clears the value of the 'metricName' field.
- * The name of this metric.
- * @return This builder.
- */
- public FlatGobblinMetric.Builder clearMetricName() {
- metricName = null;
- fieldSetFlags()[2] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'metricValue' field.
- * The value of this metric.
- * @return The value.
- */
- public java.lang.Double getMetricValue() {
- return metricValue;
- }
-
- /**
- * Sets the value of the 'metricValue' field.
- * The value of this metric.
- * @param value The value of 'metricValue'.
- * @return This builder.
- */
- public FlatGobblinMetric.Builder setMetricValue(double value) {
- validate(fields()[3], value);
- this.metricValue = value;
- fieldSetFlags()[3] = true;
- return this;
- }
-
- /**
- * Checks whether the 'metricValue' field has been set.
- * The value of this metric.
- * @return True if the 'metricValue' field has been set, false otherwise.
- */
- public boolean hasMetricValue() {
- return fieldSetFlags()[3];
- }
-
-
- /**
- * Clears the value of the 'metricValue' field.
- * The value of this metric.
- * @return This builder.
- */
- public FlatGobblinMetric.Builder clearMetricValue() {
- fieldSetFlags()[3] = false;
- return this;
- }
-
- @Override
- public FlatGobblinMetric build() {
- try {
- FlatGobblinMetric record = new FlatGobblinMetric();
- record.tags = fieldSetFlags()[0] ? this.tags : (java.util.List<java.lang.String>) defaultValue(fields()[0]);
- record.timestamp = fieldSetFlags()[1] ? this.timestamp : (java.lang.Long) defaultValue(fields()[1]);
- record.metricName = fieldSetFlags()[2] ? this.metricName : (java.lang.String) defaultValue(fields()[2]);
- record.metricValue = fieldSetFlags()[3] ? this.metricValue : (java.lang.Double) defaultValue(fields()[3]);
- return record;
- } catch (Exception e) {
- throw new org.apache.avro.AvroRuntimeException(e);
- }
- }
- }
-
- private static final org.apache.avro.io.DatumWriter
- WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$);
-
- @Override public void writeExternal(java.io.ObjectOutput out)
- throws java.io.IOException {
- WRITER$.write(this, SpecificData.getEncoder(out));
- }
-
- private static final org.apache.avro.io.DatumReader
- READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$);
-
- @Override public void readExternal(java.io.ObjectInput in)
- throws java.io.IOException {
- READER$.read(this, SpecificData.getDecoder(in));
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/588f72db/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/GobblinTrackingEvent.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/GobblinTrackingEvent.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/GobblinTrackingEvent.java
deleted file mode 100644
index 4ec7651..0000000
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/GobblinTrackingEvent.java
+++ /dev/null
@@ -1,433 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-
-import org.apache.avro.specific.SpecificData;
-
-@SuppressWarnings("all")
-@org.apache.avro.specific.AvroGenerated
-public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- private static final long serialVersionUID = 2436287129421894415L;
- public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"GobblinTrackingEvent\",\"fields\":[{\"name\":\"timestamp\",\"type\":\"long\",\"doc\":\"Time at which event was created.\",\"default\":0},{\"name\":\"namespace\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"],\"doc\":\"Namespace used for filtering of events.\"},{\"name\":\"name\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"},\"doc\":\"Event name.\"},{\"name\":\"metadata\",\"type\":{\"type\":\"map\",\"values\":{\"type\":\"string\",\"avro.java.string\":\"String\"},\"avro.java.string\":\"String\"},\"doc\":\"Event metadata.\",\"default\":{}}],\"namespace\":\"org.apache.gobblin.metrics\"}");
- public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; }
- /** Time at which event was created. */
- @Deprecated public long timestamp;
- /** Namespace used for filtering of events. */
- @Deprecated public java.lang.String namespace;
- /** Event name. */
- @Deprecated public java.lang.String name;
- /** Event metadata. */
- @Deprecated public java.util.Map<java.lang.String,java.lang.String> metadata;
-
- /**
- * Default constructor. Note that this does not initialize fields
- * to their default values from the schema. If that is desired then
- * one should use <code>newBuilder()</code>.
- */
- public GobblinTrackingEvent() {}
-
- /**
- * All-args constructor.
- * @param timestamp Time at which event was created.
- * @param namespace Namespace used for filtering of events.
- * @param name Event name.
- * @param metadata Event metadata.
- */
- public GobblinTrackingEvent(java.lang.Long timestamp, java.lang.String namespace, java.lang.String name, java.util.Map<java.lang.String,java.lang.String> metadata) {
- this.timestamp = timestamp;
- this.namespace = namespace;
- this.name = name;
- this.metadata = metadata;
- }
-
- public org.apache.avro.Schema getSchema() { return SCHEMA$; }
- // Used by DatumWriter. Applications should not call.
- public java.lang.Object get(int field$) {
- switch (field$) {
- case 0: return timestamp;
- case 1: return namespace;
- case 2: return name;
- case 3: return metadata;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-
- // Used by DatumReader. Applications should not call.
- @SuppressWarnings(value="unchecked")
- public void put(int field$, java.lang.Object value$) {
- switch (field$) {
- case 0: timestamp = (java.lang.Long)value$; break;
- case 1: namespace = (java.lang.String)value$; break;
- case 2: name = (java.lang.String)value$; break;
- case 3: metadata = (java.util.Map<java.lang.String,java.lang.String>)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-
- /**
- * Gets the value of the 'timestamp' field.
- * @return Time at which event was created.
- */
- public java.lang.Long getTimestamp() {
- return timestamp;
- }
-
- /**
- * Sets the value of the 'timestamp' field.
- * Time at which event was created.
- * @param value the value to set.
- */
- public void setTimestamp(java.lang.Long value) {
- this.timestamp = value;
- }
-
- /**
- * Gets the value of the 'namespace' field.
- * @return Namespace used for filtering of events.
- */
- public java.lang.String getNamespace() {
- return namespace;
- }
-
- /**
- * Sets the value of the 'namespace' field.
- * Namespace used for filtering of events.
- * @param value the value to set.
- */
- public void setNamespace(java.lang.String value) {
- this.namespace = value;
- }
-
- /**
- * Gets the value of the 'name' field.
- * @return Event name.
- */
- public java.lang.String getName() {
- return name;
- }
-
- /**
- * Sets the value of the 'name' field.
- * Event name.
- * @param value the value to set.
- */
- public void setName(java.lang.String value) {
- this.name = value;
- }
-
- /**
- * Gets the value of the 'metadata' field.
- * @return Event metadata.
- */
- public java.util.Map<java.lang.String,java.lang.String> getMetadata() {
- return metadata;
- }
-
- /**
- * Sets the value of the 'metadata' field.
- * Event metadata.
- * @param value the value to set.
- */
- public void setMetadata(java.util.Map<java.lang.String,java.lang.String> value) {
- this.metadata = value;
- }
-
- /**
- * Creates a new GobblinTrackingEvent RecordBuilder.
- * @return A new GobblinTrackingEvent RecordBuilder
- */
- public static GobblinTrackingEvent.Builder newBuilder() {
- return new GobblinTrackingEvent.Builder();
- }
-
- /**
- * Creates a new GobblinTrackingEvent RecordBuilder by copying an existing Builder.
- * @param other The existing builder to copy.
- * @return A new GobblinTrackingEvent RecordBuilder
- */
- public static GobblinTrackingEvent.Builder newBuilder(GobblinTrackingEvent.Builder other) {
- return new GobblinTrackingEvent.Builder(other);
- }
-
- /**
- * Creates a new GobblinTrackingEvent RecordBuilder by copying an existing GobblinTrackingEvent instance.
- * @param other The existing instance to copy.
- * @return A new GobblinTrackingEvent RecordBuilder
- */
- public static GobblinTrackingEvent.Builder newBuilder(GobblinTrackingEvent other) {
- return new GobblinTrackingEvent.Builder(other);
- }
-
- /**
- * RecordBuilder for GobblinTrackingEvent instances.
- */
- public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<GobblinTrackingEvent>
- implements org.apache.avro.data.RecordBuilder<GobblinTrackingEvent> {
-
- /** Time at which event was created. */
- private long timestamp;
- /** Namespace used for filtering of events. */
- private java.lang.String namespace;
- /** Event name. */
- private java.lang.String name;
- /** Event metadata. */
- private java.util.Map<java.lang.String,java.lang.String> metadata;
-
- /** Creates a new Builder */
- private Builder() {
- super(SCHEMA$);
- }
-
- /**
- * Creates a Builder by copying an existing Builder.
- * @param other The existing Builder to copy.
- */
- private Builder(GobblinTrackingEvent.Builder other) {
- super(other);
- if (isValidValue(fields()[0], other.timestamp)) {
- this.timestamp = data().deepCopy(fields()[0].schema(), other.timestamp);
- fieldSetFlags()[0] = true;
- }
- if (isValidValue(fields()[1], other.namespace)) {
- this.namespace = data().deepCopy(fields()[1].schema(), other.namespace);
- fieldSetFlags()[1] = true;
- }
- if (isValidValue(fields()[2], other.name)) {
- this.name = data().deepCopy(fields()[2].schema(), other.name);
- fieldSetFlags()[2] = true;
- }
- if (isValidValue(fields()[3], other.metadata)) {
- this.metadata = data().deepCopy(fields()[3].schema(), other.metadata);
- fieldSetFlags()[3] = true;
- }
- }
-
- /**
- * Creates a Builder by copying an existing GobblinTrackingEvent instance
- * @param other The existing instance to copy.
- */
- private Builder(GobblinTrackingEvent other) {
- super(SCHEMA$);
- if (isValidValue(fields()[0], other.timestamp)) {
- this.timestamp = data().deepCopy(fields()[0].schema(), other.timestamp);
- fieldSetFlags()[0] = true;
- }
- if (isValidValue(fields()[1], other.namespace)) {
- this.namespace = data().deepCopy(fields()[1].schema(), other.namespace);
- fieldSetFlags()[1] = true;
- }
- if (isValidValue(fields()[2], other.name)) {
- this.name = data().deepCopy(fields()[2].schema(), other.name);
- fieldSetFlags()[2] = true;
- }
- if (isValidValue(fields()[3], other.metadata)) {
- this.metadata = data().deepCopy(fields()[3].schema(), other.metadata);
- fieldSetFlags()[3] = true;
- }
- }
-
- /**
- * Gets the value of the 'timestamp' field.
- * Time at which event was created.
- * @return The value.
- */
- public java.lang.Long getTimestamp() {
- return timestamp;
- }
-
- /**
- * Sets the value of the 'timestamp' field.
- * Time at which event was created.
- * @param value The value of 'timestamp'.
- * @return This builder.
- */
- public GobblinTrackingEvent.Builder setTimestamp(long value) {
- validate(fields()[0], value);
- this.timestamp = value;
- fieldSetFlags()[0] = true;
- return this;
- }
-
- /**
- * Checks whether the 'timestamp' field has been set.
- * Time at which event was created.
- * @return True if the 'timestamp' field has been set, false otherwise.
- */
- public boolean hasTimestamp() {
- return fieldSetFlags()[0];
- }
-
-
- /**
- * Clears the value of the 'timestamp' field.
- * Time at which event was created.
- * @return This builder.
- */
- public GobblinTrackingEvent.Builder clearTimestamp() {
- fieldSetFlags()[0] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'namespace' field.
- * Namespace used for filtering of events.
- * @return The value.
- */
- public java.lang.String getNamespace() {
- return namespace;
- }
-
- /**
- * Sets the value of the 'namespace' field.
- * Namespace used for filtering of events.
- * @param value The value of 'namespace'.
- * @return This builder.
- */
- public GobblinTrackingEvent.Builder setNamespace(java.lang.String value) {
- validate(fields()[1], value);
- this.namespace = value;
- fieldSetFlags()[1] = true;
- return this;
- }
-
- /**
- * Checks whether the 'namespace' field has been set.
- * Namespace used for filtering of events.
- * @return True if the 'namespace' field has been set, false otherwise.
- */
- public boolean hasNamespace() {
- return fieldSetFlags()[1];
- }
-
-
- /**
- * Clears the value of the 'namespace' field.
- * Namespace used for filtering of events.
- * @return This builder.
- */
- public GobblinTrackingEvent.Builder clearNamespace() {
- namespace = null;
- fieldSetFlags()[1] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'name' field.
- * Event name.
- * @return The value.
- */
- public java.lang.String getName() {
- return name;
- }
-
- /**
- * Sets the value of the 'name' field.
- * Event name.
- * @param value The value of 'name'.
- * @return This builder.
- */
- public GobblinTrackingEvent.Builder setName(java.lang.String value) {
- validate(fields()[2], value);
- this.name = value;
- fieldSetFlags()[2] = true;
- return this;
- }
-
- /**
- * Checks whether the 'name' field has been set.
- * Event name.
- * @return True if the 'name' field has been set, false otherwise.
- */
- public boolean hasName() {
- return fieldSetFlags()[2];
- }
-
-
- /**
- * Clears the value of the 'name' field.
- * Event name.
- * @return This builder.
- */
- public GobblinTrackingEvent.Builder clearName() {
- name = null;
- fieldSetFlags()[2] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'metadata' field.
- * Event metadata.
- * @return The value.
- */
- public java.util.Map<java.lang.String,java.lang.String> getMetadata() {
- return metadata;
- }
-
- /**
- * Sets the value of the 'metadata' field.
- * Event metadata.
- * @param value The value of 'metadata'.
- * @return This builder.
- */
- public GobblinTrackingEvent.Builder setMetadata(java.util.Map<java.lang.String,java.lang.String> value) {
- validate(fields()[3], value);
- this.metadata = value;
- fieldSetFlags()[3] = true;
- return this;
- }
-
- /**
- * Checks whether the 'metadata' field has been set.
- * Event metadata.
- * @return True if the 'metadata' field has been set, false otherwise.
- */
- public boolean hasMetadata() {
- return fieldSetFlags()[3];
- }
-
-
- /**
- * Clears the value of the 'metadata' field.
- * Event metadata.
- * @return This builder.
- */
- public GobblinTrackingEvent.Builder clearMetadata() {
- metadata = null;
- fieldSetFlags()[3] = false;
- return this;
- }
-
- @Override
- public GobblinTrackingEvent build() {
- try {
- GobblinTrackingEvent record = new GobblinTrackingEvent();
- record.timestamp = fieldSetFlags()[0] ? this.timestamp : (java.lang.Long) defaultValue(fields()[0]);
- record.namespace = fieldSetFlags()[1] ? this.namespace : (java.lang.String) defaultValue(fields()[1]);
- record.name = fieldSetFlags()[2] ? this.name : (java.lang.String) defaultValue(fields()[2]);
- record.metadata = fieldSetFlags()[3] ? this.metadata : (java.util.Map<java.lang.String,java.lang.String>) defaultValue(fields()[3]);
- return record;
- } catch (Exception e) {
- throw new org.apache.avro.AvroRuntimeException(e);
- }
- }
- }
-
- private static final org.apache.avro.io.DatumWriter
- WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$);
-
- @Override public void writeExternal(java.io.ObjectOutput out)
- throws java.io.IOException {
- WRITER$.write(this, SpecificData.getEncoder(out));
- }
-
- private static final org.apache.avro.io.DatumReader
- READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$);
-
- @Override public void readExternal(java.io.ObjectInput in)
- throws java.io.IOException {
- READER$.read(this, SpecificData.getDecoder(in));
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/588f72db/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/Metric.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/Metric.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/Metric.java
deleted file mode 100644
index 237b8c4..0000000
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/Metric.java
+++ /dev/null
@@ -1,279 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-
-import org.apache.avro.specific.SpecificData;
-
-@SuppressWarnings("all")
-@org.apache.avro.specific.AvroGenerated
-public class Metric extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- private static final long serialVersionUID = 2082125793684587136L;
- public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"Metric\",\"fields\":[{\"name\":\"name\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"},\"doc\":\"Metric name.\"},{\"name\":\"value\",\"type\":\"double\",\"doc\":\"Metric value.\"}]}");
- public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; }
- /** Metric name. */
- @Deprecated public java.lang.String name;
- /** Metric value. */
- @Deprecated public double value;
-
- /**
- * Default constructor. Note that this does not initialize fields
- * to their default values from the schema. If that is desired then
- * one should use <code>newBuilder()</code>.
- */
- public Metric() {}
-
- /**
- * All-args constructor.
- * @param name Metric name.
- * @param value Metric value.
- */
- public Metric(java.lang.String name, java.lang.Double value) {
- this.name = name;
- this.value = value;
- }
-
- public org.apache.avro.Schema getSchema() { return SCHEMA$; }
- // Used by DatumWriter. Applications should not call.
- public java.lang.Object get(int field$) {
- switch (field$) {
- case 0: return name;
- case 1: return value;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-
- // Used by DatumReader. Applications should not call.
- @SuppressWarnings(value="unchecked")
- public void put(int field$, java.lang.Object value$) {
- switch (field$) {
- case 0: name = (java.lang.String)value$; break;
- case 1: value = (java.lang.Double)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-
- /**
- * Gets the value of the 'name' field.
- * @return Metric name.
- */
- public java.lang.String getName() {
- return name;
- }
-
- /**
- * Sets the value of the 'name' field.
- * Metric name.
- * @param value the value to set.
- */
- public void setName(java.lang.String value) {
- this.name = value;
- }
-
- /**
- * Gets the value of the 'value' field.
- * @return Metric value.
- */
- public java.lang.Double getValue() {
- return value;
- }
-
- /**
- * Sets the value of the 'value' field.
- * Metric value.
- * @param value the value to set.
- */
- public void setValue(java.lang.Double value) {
- this.value = value;
- }
-
- /**
- * Creates a new Metric RecordBuilder.
- * @return A new Metric RecordBuilder
- */
- public static Metric.Builder newBuilder() {
- return new Metric.Builder();
- }
-
- /**
- * Creates a new Metric RecordBuilder by copying an existing Builder.
- * @param other The existing builder to copy.
- * @return A new Metric RecordBuilder
- */
- public static Metric.Builder newBuilder(Metric.Builder other) {
- return new Metric.Builder(other);
- }
-
- /**
- * Creates a new Metric RecordBuilder by copying an existing Metric instance.
- * @param other The existing instance to copy.
- * @return A new Metric RecordBuilder
- */
- public static Metric.Builder newBuilder(Metric other) {
- return new Metric.Builder(other);
- }
-
- /**
- * RecordBuilder for Metric instances.
- */
- public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<Metric>
- implements org.apache.avro.data.RecordBuilder<Metric> {
-
- /** Metric name. */
- private java.lang.String name;
- /** Metric value. */
- private double value;
-
- /** Creates a new Builder */
- private Builder() {
- super(SCHEMA$);
- }
-
- /**
- * Creates a Builder by copying an existing Builder.
- * @param other The existing Builder to copy.
- */
- private Builder(Metric.Builder other) {
- super(other);
- if (isValidValue(fields()[0], other.name)) {
- this.name = data().deepCopy(fields()[0].schema(), other.name);
- fieldSetFlags()[0] = true;
- }
- if (isValidValue(fields()[1], other.value)) {
- this.value = data().deepCopy(fields()[1].schema(), other.value);
- fieldSetFlags()[1] = true;
- }
- }
-
- /**
- * Creates a Builder by copying an existing Metric instance
- * @param other The existing instance to copy.
- */
- private Builder(Metric other) {
- super(SCHEMA$);
- if (isValidValue(fields()[0], other.name)) {
- this.name = data().deepCopy(fields()[0].schema(), other.name);
- fieldSetFlags()[0] = true;
- }
- if (isValidValue(fields()[1], other.value)) {
- this.value = data().deepCopy(fields()[1].schema(), other.value);
- fieldSetFlags()[1] = true;
- }
- }
-
- /**
- * Gets the value of the 'name' field.
- * Metric name.
- * @return The value.
- */
- public java.lang.String getName() {
- return name;
- }
-
- /**
- * Sets the value of the 'name' field.
- * Metric name.
- * @param value The value of 'name'.
- * @return This builder.
- */
- public Metric.Builder setName(java.lang.String value) {
- validate(fields()[0], value);
- this.name = value;
- fieldSetFlags()[0] = true;
- return this;
- }
-
- /**
- * Checks whether the 'name' field has been set.
- * Metric name.
- * @return True if the 'name' field has been set, false otherwise.
- */
- public boolean hasName() {
- return fieldSetFlags()[0];
- }
-
-
- /**
- * Clears the value of the 'name' field.
- * Metric name.
- * @return This builder.
- */
- public Metric.Builder clearName() {
- name = null;
- fieldSetFlags()[0] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'value' field.
- * Metric value.
- * @return The value.
- */
- public java.lang.Double getValue() {
- return value;
- }
-
- /**
- * Sets the value of the 'value' field.
- * Metric value.
- * @param value The value of 'value'.
- * @return This builder.
- */
- public Metric.Builder setValue(double value) {
- validate(fields()[1], value);
- this.value = value;
- fieldSetFlags()[1] = true;
- return this;
- }
-
- /**
- * Checks whether the 'value' field has been set.
- * Metric value.
- * @return True if the 'value' field has been set, false otherwise.
- */
- public boolean hasValue() {
- return fieldSetFlags()[1];
- }
-
-
- /**
- * Clears the value of the 'value' field.
- * Metric value.
- * @return This builder.
- */
- public Metric.Builder clearValue() {
- fieldSetFlags()[1] = false;
- return this;
- }
-
- @Override
- public Metric build() {
- try {
- Metric record = new Metric();
- record.name = fieldSetFlags()[0] ? this.name : (java.lang.String) defaultValue(fields()[0]);
- record.value = fieldSetFlags()[1] ? this.value : (java.lang.Double) defaultValue(fields()[1]);
- return record;
- } catch (Exception e) {
- throw new org.apache.avro.AvroRuntimeException(e);
- }
- }
- }
-
- private static final org.apache.avro.io.DatumWriter
- WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$);
-
- @Override public void writeExternal(java.io.ObjectOutput out)
- throws java.io.IOException {
- WRITER$.write(this, SpecificData.getEncoder(out));
- }
-
- private static final org.apache.avro.io.DatumReader
- READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$);
-
- @Override public void readExternal(java.io.ObjectInput in)
- throws java.io.IOException {
- READER$.read(this, SpecificData.getDecoder(in));
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/588f72db/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/MetricReport.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/MetricReport.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/MetricReport.java
deleted file mode 100644
index 6bccda9..0000000
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/MetricReport.java
+++ /dev/null
@@ -1,356 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-
-import org.apache.avro.specific.SpecificData;
-
-@SuppressWarnings("all")
-@org.apache.avro.specific.AvroGenerated
-public class MetricReport extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- private static final long serialVersionUID = -3871534513744778107L;
- public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"MetricReport\",\"fields\":[{\"name\":\"tags\",\"type\":{\"type\":\"map\",\"values\":{\"type\":\"string\",\"avro.java.string\":\"String\"},\"avro.java.string\":\"String\"},\"doc\":\"Tags associated with the metrics.\"},{\"name\":\"timestamp\",\"type\":\"long\",\"doc\":\"Time at which metrics were reported.\"},{\"name\":\"metrics\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"Metric\",\"fields\":[{\"name\":\"name\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"},\"doc\":\"Metric name.\"},{\"name\":\"value\",\"type\":\"double\",\"doc\":\"Metric value.\"}]}},\"doc\":\"Array of metrics in this report.\"}],\"namespace\":\"org.apache.gobblin.metrics\"}");
- public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; }
- /** Tags associated with the metrics. */
- @Deprecated public java.util.Map<java.lang.String,java.lang.String> tags;
- /** Time at which metrics were reported. */
- @Deprecated public long timestamp;
- /** Array of metrics in this report. */
- @Deprecated public java.util.List<Metric> metrics;
-
- /**
- * Default constructor. Note that this does not initialize fields
- * to their default values from the schema. If that is desired then
- * one should use <code>newBuilder()</code>.
- */
- public MetricReport() {}
-
- /**
- * All-args constructor.
- * @param tags Tags associated with the metrics.
- * @param timestamp Time at which metrics were reported.
- * @param metrics Array of metrics in this report.
- */
- public MetricReport(java.util.Map<java.lang.String,java.lang.String> tags, java.lang.Long timestamp, java.util.List<Metric> metrics) {
- this.tags = tags;
- this.timestamp = timestamp;
- this.metrics = metrics;
- }
-
- public org.apache.avro.Schema getSchema() { return SCHEMA$; }
- // Used by DatumWriter. Applications should not call.
- public java.lang.Object get(int field$) {
- switch (field$) {
- case 0: return tags;
- case 1: return timestamp;
- case 2: return metrics;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-
- // Used by DatumReader. Applications should not call.
- @SuppressWarnings(value="unchecked")
- public void put(int field$, java.lang.Object value$) {
- switch (field$) {
- case 0: tags = (java.util.Map<java.lang.String,java.lang.String>)value$; break;
- case 1: timestamp = (java.lang.Long)value$; break;
- case 2: metrics = (java.util.List<Metric>)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-
- /**
- * Gets the value of the 'tags' field.
- * @return Tags associated with the metrics.
- */
- public java.util.Map<java.lang.String,java.lang.String> getTags() {
- return tags;
- }
-
- /**
- * Sets the value of the 'tags' field.
- * Tags associated with the metrics.
- * @param value the value to set.
- */
- public void setTags(java.util.Map<java.lang.String,java.lang.String> value) {
- this.tags = value;
- }
-
- /**
- * Gets the value of the 'timestamp' field.
- * @return Time at which metrics were reported.
- */
- public java.lang.Long getTimestamp() {
- return timestamp;
- }
-
- /**
- * Sets the value of the 'timestamp' field.
- * Time at which metrics were reported.
- * @param value the value to set.
- */
- public void setTimestamp(java.lang.Long value) {
- this.timestamp = value;
- }
-
- /**
- * Gets the value of the 'metrics' field.
- * @return Array of metrics in this report.
- */
- public java.util.List<Metric> getMetrics() {
- return metrics;
- }
-
- /**
- * Sets the value of the 'metrics' field.
- * Array of metrics in this report.
- * @param value the value to set.
- */
- public void setMetrics(java.util.List<Metric> value) {
- this.metrics = value;
- }
-
- /**
- * Creates a new MetricReport RecordBuilder.
- * @return A new MetricReport RecordBuilder
- */
- public static MetricReport.Builder newBuilder() {
- return new MetricReport.Builder();
- }
-
- /**
- * Creates a new MetricReport RecordBuilder by copying an existing Builder.
- * @param other The existing builder to copy.
- * @return A new MetricReport RecordBuilder
- */
- public static MetricReport.Builder newBuilder(MetricReport.Builder other) {
- return new MetricReport.Builder(other);
- }
-
- /**
- * Creates a new MetricReport RecordBuilder by copying an existing MetricReport instance.
- * @param other The existing instance to copy.
- * @return A new MetricReport RecordBuilder
- */
- public static MetricReport.Builder newBuilder(MetricReport other) {
- return new MetricReport.Builder(other);
- }
-
- /**
- * RecordBuilder for MetricReport instances.
- */
- public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<MetricReport>
- implements org.apache.avro.data.RecordBuilder<MetricReport> {
-
- /** Tags associated with the metrics. */
- private java.util.Map<java.lang.String,java.lang.String> tags;
- /** Time at which metrics were reported. */
- private long timestamp;
- /** Array of metrics in this report. */
- private java.util.List<Metric> metrics;
-
- /** Creates a new Builder */
- private Builder() {
- super(SCHEMA$);
- }
-
- /**
- * Creates a Builder by copying an existing Builder.
- * @param other The existing Builder to copy.
- */
- private Builder(MetricReport.Builder other) {
- super(other);
- if (isValidValue(fields()[0], other.tags)) {
- this.tags = data().deepCopy(fields()[0].schema(), other.tags);
- fieldSetFlags()[0] = true;
- }
- if (isValidValue(fields()[1], other.timestamp)) {
- this.timestamp = data().deepCopy(fields()[1].schema(), other.timestamp);
- fieldSetFlags()[1] = true;
- }
- if (isValidValue(fields()[2], other.metrics)) {
- this.metrics = data().deepCopy(fields()[2].schema(), other.metrics);
- fieldSetFlags()[2] = true;
- }
- }
-
- /**
- * Creates a Builder by copying an existing MetricReport instance
- * @param other The existing instance to copy.
- */
- private Builder(MetricReport other) {
- super(SCHEMA$);
- if (isValidValue(fields()[0], other.tags)) {
- this.tags = data().deepCopy(fields()[0].schema(), other.tags);
- fieldSetFlags()[0] = true;
- }
- if (isValidValue(fields()[1], other.timestamp)) {
- this.timestamp = data().deepCopy(fields()[1].schema(), other.timestamp);
- fieldSetFlags()[1] = true;
- }
- if (isValidValue(fields()[2], other.metrics)) {
- this.metrics = data().deepCopy(fields()[2].schema(), other.metrics);
- fieldSetFlags()[2] = true;
- }
- }
-
- /**
- * Gets the value of the 'tags' field.
- * Tags associated with the metrics.
- * @return The value.
- */
- public java.util.Map<java.lang.String,java.lang.String> getTags() {
- return tags;
- }
-
- /**
- * Sets the value of the 'tags' field.
- * Tags associated with the metrics.
- * @param value The value of 'tags'.
- * @return This builder.
- */
- public MetricReport.Builder setTags(java.util.Map<java.lang.String,java.lang.String> value) {
- validate(fields()[0], value);
- this.tags = value;
- fieldSetFlags()[0] = true;
- return this;
- }
-
- /**
- * Checks whether the 'tags' field has been set.
- * Tags associated with the metrics.
- * @return True if the 'tags' field has been set, false otherwise.
- */
- public boolean hasTags() {
- return fieldSetFlags()[0];
- }
-
-
- /**
- * Clears the value of the 'tags' field.
- * Tags associated with the metrics.
- * @return This builder.
- */
- public MetricReport.Builder clearTags() {
- tags = null;
- fieldSetFlags()[0] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'timestamp' field.
- * Time at which metrics were reported.
- * @return The value.
- */
- public java.lang.Long getTimestamp() {
- return timestamp;
- }
-
- /**
- * Sets the value of the 'timestamp' field.
- * Time at which metrics were reported.
- * @param value The value of 'timestamp'.
- * @return This builder.
- */
- public MetricReport.Builder setTimestamp(long value) {
- validate(fields()[1], value);
- this.timestamp = value;
- fieldSetFlags()[1] = true;
- return this;
- }
-
- /**
- * Checks whether the 'timestamp' field has been set.
- * Time at which metrics were reported.
- * @return True if the 'timestamp' field has been set, false otherwise.
- */
- public boolean hasTimestamp() {
- return fieldSetFlags()[1];
- }
-
-
- /**
- * Clears the value of the 'timestamp' field.
- * Time at which metrics were reported.
- * @return This builder.
- */
- public MetricReport.Builder clearTimestamp() {
- fieldSetFlags()[1] = false;
- return this;
- }
-
- /**
- * Gets the value of the 'metrics' field.
- * Array of metrics in this report.
- * @return The value.
- */
- public java.util.List<Metric> getMetrics() {
- return metrics;
- }
-
- /**
- * Sets the value of the 'metrics' field.
- * Array of metrics in this report.
- * @param value The value of 'metrics'.
- * @return This builder.
- */
- public MetricReport.Builder setMetrics(java.util.List<Metric> value) {
- validate(fields()[2], value);
- this.metrics = value;
- fieldSetFlags()[2] = true;
- return this;
- }
-
- /**
- * Checks whether the 'metrics' field has been set.
- * Array of metrics in this report.
- * @return True if the 'metrics' field has been set, false otherwise.
- */
- public boolean hasMetrics() {
- return fieldSetFlags()[2];
- }
-
-
- /**
- * Clears the value of the 'metrics' field.
- * Array of metrics in this report.
- * @return This builder.
- */
- public MetricReport.Builder clearMetrics() {
- metrics = null;
- fieldSetFlags()[2] = false;
- return this;
- }
-
- @Override
- public MetricReport build() {
- try {
- MetricReport record = new MetricReport();
- record.tags = fieldSetFlags()[0] ? this.tags : (java.util.Map<java.lang.String,java.lang.String>) defaultValue(fields()[0]);
- record.timestamp = fieldSetFlags()[1] ? this.timestamp : (java.lang.Long) defaultValue(fields()[1]);
- record.metrics = fieldSetFlags()[2] ? this.metrics : (java.util.List<Metric>) defaultValue(fields()[2]);
- return record;
- } catch (Exception e) {
- throw new org.apache.avro.AvroRuntimeException(e);
- }
- }
- }
-
- private static final org.apache.avro.io.DatumWriter
- WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$);
-
- @Override public void writeExternal(java.io.ObjectOutput out)
- throws java.io.IOException {
- WRITER$.write(this, SpecificData.getEncoder(out));
- }
-
- private static final org.apache.avro.io.DatumReader
- READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$);
-
- @Override public void readExternal(java.io.ObjectInput in)
- throws java.io.IOException {
- READER$.read(this, SpecificData.getDecoder(in));
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/588f72db/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 11bd64a..0a5a2da 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
@@ -44,12 +44,12 @@ import org.apache.gobblin.service.monitoring.JobStatusRetriever;
public class FlowStatusTest {
private FlowStatusClient _client;
private EmbeddedRestliServer _server;
- private List<List<gobblin.service.monitoring.JobStatus>> _listOfJobStatusLists;
+ private List<List<org.apache.gobblin.service.monitoring.JobStatus>> _listOfJobStatusLists;
private Joiner messageJoiner;
class TestJobStatusRetriever extends JobStatusRetriever {
@Override
- public Iterator<gobblin.service.monitoring.JobStatus> getJobStatusesForFlowExecution(String flowName,
+ public Iterator<org.apache.gobblin.service.monitoring.JobStatus> getJobStatusesForFlowExecution(String flowName,
String flowGroup, long flowExecutionId) {
return _listOfJobStatusLists.get((int)flowExecutionId).iterator();
}
@@ -102,8 +102,8 @@ public class FlowStatusTest {
.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();
- List<gobblin.service.monitoring.JobStatus> jobStatusList1 = Lists.newArrayList(js1);
- List<gobblin.service.monitoring.JobStatus> jobStatusList2 = Lists.newArrayList(js2);
+ List<org.apache.gobblin.service.monitoring.JobStatus> jobStatusList1 = Lists.newArrayList(js1);
+ List<org.apache.gobblin.service.monitoring.JobStatus> jobStatusList2 = Lists.newArrayList(js2);
_listOfJobStatusLists = Lists.newArrayList();
_listOfJobStatusLists.add(jobStatusList1);
_listOfJobStatusLists.add(jobStatusList2);
@@ -144,7 +144,7 @@ public class FlowStatusTest {
.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();
- List<gobblin.service.monitoring.JobStatus> jobStatusList = Lists.newArrayList(js1, js2);
+ List<org.apache.gobblin.service.monitoring.JobStatus> jobStatusList = Lists.newArrayList(js1, js2);
_listOfJobStatusLists = Lists.newArrayList();
_listOfJobStatusLists.add(jobStatusList);
@@ -184,7 +184,7 @@ public class FlowStatusTest {
.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();
- List<gobblin.service.monitoring.JobStatus> jobStatusList = Lists.newArrayList(js1, js2);
+ List<org.apache.gobblin.service.monitoring.JobStatus> jobStatusList = Lists.newArrayList(js1, js2);
_listOfJobStatusLists = Lists.newArrayList();
_listOfJobStatusLists.add(jobStatusList);
@@ -224,7 +224,7 @@ public class FlowStatusTest {
.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();
- List<gobblin.service.monitoring.JobStatus> jobStatusList = Lists.newArrayList(js1, js2);
+ List<org.apache.gobblin.service.monitoring.JobStatus> jobStatusList = Lists.newArrayList(js1, js2);
_listOfJobStatusLists = Lists.newArrayList();
_listOfJobStatusLists.add(jobStatusList);
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/588f72db/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 1800739..584c57c 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
@@ -99,7 +99,7 @@ public class FlowStatusResource extends ComplexKeyResourceTemplate<FlowStatusId,
return null;
}
- Iterator<gobblin.service.monitoring.JobStatus> jobStatusIter = monitoringFlowStatus.getJobStatusIterator();
+ Iterator<org.apache.gobblin.service.monitoring.JobStatus> jobStatusIter = monitoringFlowStatus.getJobStatusIterator();
JobStatusArray jobStatusArray = new JobStatusArray();
FlowId flowId = new FlowId().setFlowName(monitoringFlowStatus.getFlowName())
.setFlowGroup(monitoringFlowStatus.getFlowGroup());