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 <[email protected]> Authored: Tue Oct 20 18:11:36 2015 -0700 Committer: Thomas Weise <[email protected]> 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;
