gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [66/77] [abbrv] incubator-gobblin git commit: Update package from gobblin to org.apache.gobblin for typed references
Date Mon, 31 Jul 2017 07:53:24 GMT
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 <abhishektiwari.btech@gmail.com>
Authored: Sun Jul 30 20:21:46 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.btech@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());


Mime
View raw message