You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2015/11/03 03:27:34 UTC
[33/50] [abbrv] incubator-apex-core git commit: Add since tags for
release 3.2.0
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/master
Commit: 42927bc5c00d8c1a2f75f046434a2fc69594da2e
Parents: 5a90bb7
Author: Thomas Weise <th...@datatorrent.com>
Authored: Tue Oct 20 18:11:36 2015 -0700
Committer: Thomas Weise <th...@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;