apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From david...@apache.org
Subject incubator-apex-core git commit: Add since tags for release 3.2.0
Date Wed, 21 Oct 2015 01:41:44 GMT
Repository: incubator-apex-core
Updated Branches:
  refs/heads/release-3.2 5a90bb701 -> 42927bc5c


Add since tags for release 3.2.0


Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/42927bc5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/42927bc5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/42927bc5

Branch: refs/heads/release-3.2
Commit: 42927bc5c00d8c1a2f75f046434a2fc69594da2e
Parents: 5a90bb7
Author: Thomas Weise <thomas@datatorrent.com>
Authored: Tue Oct 20 18:11:36 2015 -0700
Committer: Thomas Weise <thomas@datatorrent.com>
Committed: Tue Oct 20 18:30:48 2015 -0700

----------------------------------------------------------------------
 api/src/main/java/com/datatorrent/api/annotation/Name.java     | 5 +++++
 .../main/java/com/datatorrent/bufferserver/util/VarInt.java    | 5 +++++
 .../com/datatorrent/common/metric/SingleMetricAggregator.java  | 5 +++++
 .../com/datatorrent/common/metric/sum/DoubleSumAggregator.java | 5 +++++
 .../com/datatorrent/common/metric/sum/LongSumAggregator.java   | 5 +++++
 .../src/main/java/com/datatorrent/stram/api/AppDataSource.java | 5 +++++
 engine/src/main/java/com/datatorrent/stram/engine/Slider.java  | 5 +++++
 .../datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java | 2 ++
 .../stram/plan/logical/StreamCodecWrapperForPersistance.java   | 6 +++++-
 .../stram/stream/PartitionAwareSinkForPersistence.java         | 6 +++++-
 .../main/java/com/datatorrent/stram/webapp/ContainerInfo.java  | 5 +++++
 .../datatorrent/stram/webapp/asm/CompactAnnotationNode.java    | 5 +++++
 .../com/datatorrent/stram/webapp/asm/CompactFieldNode.java     | 5 +++++
 .../datatorrent/stram/webapp/asm/FieldSignatureVisitor.java    | 5 +++++
 14 files changed, 67 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/api/src/main/java/com/datatorrent/api/annotation/Name.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/annotation/Name.java b/api/src/main/java/com/datatorrent/api/annotation/Name.java
index a93f59c..2d03a92 100644
--- a/api/src/main/java/com/datatorrent/api/annotation/Name.java
+++ b/api/src/main/java/com/datatorrent/api/annotation/Name.java
@@ -20,6 +20,11 @@ package com.datatorrent.api.annotation;
 
 import java.lang.annotation.*;
 
+/**
+ * <p>Name class.</p>
+ *
+ * @since 3.2.0
+ */
 @Documented
 @Target(ElementType.TYPE)
 @Retention(RetentionPolicy.RUNTIME)

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java
----------------------------------------------------------------------
diff --git a/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java b/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java
index 0c54429..6f12cc4 100644
--- a/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java
+++ b/bufferserver/src/main/java/com/datatorrent/bufferserver/util/VarInt.java
@@ -17,6 +17,11 @@
  * under the License.
  */
 package com.datatorrent.bufferserver.util;
+/**
+ * <p>VarInt class.</p>
+ *
+ * @since 3.2.0
+ */
 public class VarInt extends com.datatorrent.netlet.util.VarInt
 {
   public static void read(SerializedData current)

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
b/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
index 468e5c6..9b568d2 100644
--- a/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
+++ b/common/src/main/java/com/datatorrent/common/metric/SingleMetricAggregator.java
@@ -19,6 +19,11 @@
 package com.datatorrent.common.metric;
 
 import java.util.Collection;
+/**
+ * <p>SingleMetricAggregator interface.</p>
+ *
+ * @since 3.2.0
+ */
 public interface SingleMetricAggregator
 {
   Object aggregate(Collection<Object> metricValues);

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
b/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
index ee6df6b..70e6c61 100644
--- a/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
+++ b/common/src/main/java/com/datatorrent/common/metric/sum/DoubleSumAggregator.java
@@ -25,6 +25,11 @@ import com.datatorrent.api.annotation.Name;
 
 import com.datatorrent.common.metric.SingleMetricAggregator;
 
+/**
+ * <p>DoubleSumAggregator class.</p>
+ *
+ * @since 3.2.0
+ */
 @Name("sum")
 public class DoubleSumAggregator implements SingleMetricAggregator, Serializable
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
b/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
index e1cb869..ad88dda 100644
--- a/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
+++ b/common/src/main/java/com/datatorrent/common/metric/sum/LongSumAggregator.java
@@ -25,6 +25,11 @@ import com.datatorrent.api.annotation.Name;
 
 import com.datatorrent.common.metric.SingleMetricAggregator;
 
+/**
+ * <p>LongSumAggregator class.</p>
+ *
+ * @since 3.2.0
+ */
 @Name("sum")
 public class LongSumAggregator implements SingleMetricAggregator, Serializable
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java b/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java
index 1246721..e6a4606 100644
--- a/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java
+++ b/engine/src/main/java/com/datatorrent/stram/api/AppDataSource.java
@@ -21,6 +21,11 @@ package com.datatorrent.stram.api;
 import java.util.Map;
 import org.codehaus.jackson.map.annotate.JsonSerialize;
 
+/**
+ * <p>AppDataSource class.</p>
+ *
+ * @since 3.2.0
+ */
 @JsonSerialize(include = JsonSerialize.Inclusion.NON_NULL)
 public class AppDataSource
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/engine/Slider.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/engine/Slider.java b/engine/src/main/java/com/datatorrent/stram/engine/Slider.java
index 27b77e8..d6c1b5c 100644
--- a/engine/src/main/java/com/datatorrent/stram/engine/Slider.java
+++ b/engine/src/main/java/com/datatorrent/stram/engine/Slider.java
@@ -26,6 +26,11 @@ import java.util.List;
 import com.datatorrent.api.*;
 import com.datatorrent.api.Context.OperatorContext;
 import com.datatorrent.api.Operator.Unifier;
+/**
+ * <p>Slider class.</p>
+ *
+ * @since 3.2.0
+ */
 public class Slider implements Unifier<Object>, Operator.IdleTimeHandler, Operator.ActivationListener<OperatorContext>,
StatsListener, Serializable, Operator.CheckpointListener
 {
   private List<List<Object>> cache;

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
b/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
index 2dcb998..23009e3 100644
--- a/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
+++ b/engine/src/main/java/com/datatorrent/stram/plan/logical/DefaultKryoStreamCodec.java
@@ -36,6 +36,8 @@ import com.datatorrent.netlet.util.Slice;
 /**
  * This codec is used for serializing the objects of class which are Kryo
  * serializable. Used for stream codec wrapper used for persistence
+ *
+ * @since 3.2.0
  */
 public class DefaultKryoStreamCodec<T> extends SerializableObject implements StreamCodec<T>
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
b/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
index 17be686..c6ac5e7 100644
--- a/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
+++ b/engine/src/main/java/com/datatorrent/stram/plan/logical/StreamCodecWrapperForPersistance.java
@@ -29,7 +29,11 @@ import com.datatorrent.api.Partitioner.PartitionKeys;
 import com.datatorrent.api.StreamCodec;
 import com.datatorrent.netlet.util.Slice;
 import com.datatorrent.stram.plan.logical.LogicalPlan.InputPortMeta;
-
+/**
+ * <p>StreamCodecWrapperForPersistance class.</p>
+ *
+ * @since 3.2.0
+ */
 public class StreamCodecWrapperForPersistance<T> implements StreamCodec<T>, Serializable
 {
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
b/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
index e5a2b77..b6fdbe9 100644
--- a/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
+++ b/engine/src/main/java/com/datatorrent/stram/stream/PartitionAwareSinkForPersistence.java
@@ -23,7 +23,11 @@ import java.util.Set;
 
 import com.datatorrent.api.Sink;
 import com.datatorrent.stram.plan.logical.StreamCodecWrapperForPersistance;
-
+/**
+ * <p>PartitionAwareSinkForPersistence class.</p>
+ *
+ * @since 3.2.0
+ */
 public class PartitionAwareSinkForPersistence extends PartitionAwareSink<Object>
 {
   StreamCodecWrapperForPersistance<Object> serdeForPersistence;

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java b/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java
index b3e15c3..06300ce 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java
@@ -24,6 +24,11 @@ import javax.xml.bind.annotation.XmlRootElement;
 
 import com.datatorrent.api.annotation.RecordField;
 
+/**
+ * <p>ContainerInfo class.</p>
+ *
+ * @since 3.2.0
+ */
 @XmlRootElement(name = "container")
 @XmlAccessorType(XmlAccessType.FIELD)
 public class ContainerInfo {

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
b/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
index 99ddd75..7860378 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactAnnotationNode.java
@@ -19,6 +19,11 @@
 package com.datatorrent.stram.webapp.asm;
 
 import java.util.Map;
+/**
+ * <p>CompactAnnotationNode class.</p>
+ *
+ * @since 3.2.0
+ */
 public class CompactAnnotationNode {
 
   private String desc;

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java b/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java
index bd5991e..778fc41 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/asm/CompactFieldNode.java
@@ -23,6 +23,11 @@ import java.util.List;
 
 import org.apache.xbean.asm5.tree.AnnotationNode;
 import org.apache.xbean.asm5.tree.FieldNode;
+/**
+ * <p>CompactFieldNode class.</p>
+ *
+ * @since 3.2.0
+ */
 public class CompactFieldNode {
   private String name;
   private String desc;

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/42927bc5/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
b/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
index c58fe7b..24b71d9 100644
--- a/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
+++ b/engine/src/main/java/com/datatorrent/stram/webapp/asm/FieldSignatureVisitor.java
@@ -20,6 +20,11 @@ package com.datatorrent.stram.webapp.asm;
 
 
 import org.apache.xbean.asm5.signature.SignatureVisitor;
+/**
+ * <p>FieldSignatureVisitor class.</p>
+ *
+ * @since 3.2.0
+ */
 public class FieldSignatureVisitor extends BaseSignatureVisitor{
 
   private Type fieldType;


Mime
View raw message