apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [1/3] apex-malhar git commit: Add @since tags and update change log for release 3.5.0
Date Sun, 04 Sep 2016 07:42:26 GMT
Repository: apex-malhar
Updated Branches:
  refs/heads/release-3.5 2aabd7b0d -> 9bcffafe4


http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Min.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Min.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Min.java
index 0460052..48017a7 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Min.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/Min.java
@@ -23,6 +23,8 @@ import org.apache.apex.malhar.lib.window.Accumulation;
 
 /**
  * Min accumulation
+ *
+ * @since 3.5.0
  */
 public class Min<T> implements Accumulation<T, T, T>
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/ReduceFn.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/ReduceFn.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/ReduceFn.java
index 0c34c75..2b1b635 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/ReduceFn.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/ReduceFn.java
@@ -23,6 +23,8 @@ import org.apache.apex.malhar.lib.window.Accumulation;
 /**
  * An easy to use reduce Accumulation
  * @param <INPUT>
+ *
+ * @since 3.5.0
  */
 public abstract class ReduceFn<INPUT> implements Accumulation<INPUT, INPUT, INPUT>
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/RemoveDuplicates.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/RemoveDuplicates.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/RemoveDuplicates.java
index 8eee868..2548f72 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/RemoveDuplicates.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/RemoveDuplicates.java
@@ -28,6 +28,8 @@ import org.apache.apex.malhar.lib.window.Accumulation;
 /**
  * RemoveDuplicates Accumulation.
  * @param <T>
+ *
+ * @since 3.5.0
  */
 public class RemoveDuplicates<T> implements Accumulation<T, Set<T>, List<T>>
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumDouble.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumDouble.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumDouble.java
index fafff43..11ab2ab 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumDouble.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumDouble.java
@@ -23,6 +23,8 @@ import org.apache.commons.lang.mutable.MutableDouble;
 
 /**
  * Sum Accumulation for doubles.
+ *
+ * @since 3.5.0
  */
 public class SumDouble implements Accumulation<Double, MutableDouble, Double>
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumFloat.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumFloat.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumFloat.java
index 2e2d3ef..d11bec3 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumFloat.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumFloat.java
@@ -23,6 +23,8 @@ import org.apache.commons.lang.mutable.MutableFloat;
 
 /**
  * Sum Accumulation for floats.
+ *
+ * @since 3.5.0
  */
 public class SumFloat implements Accumulation<Float, MutableFloat, Float>
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumInt.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumInt.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumInt.java
index c9aa4bd..cf0c50e 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumInt.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumInt.java
@@ -23,6 +23,8 @@ import org.apache.commons.lang.mutable.MutableInt;
 
 /**
  * Sum accumulation for integers.
+ *
+ * @since 3.5.0
  */
 public class SumInt implements Accumulation<Integer, MutableInt, Integer>
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumLong.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumLong.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumLong.java
index 1268141..55908f5 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumLong.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/SumLong.java
@@ -23,6 +23,8 @@ import org.apache.commons.lang.mutable.MutableLong;
 
 /**
  * Sum accumulation for longs.
+ *
+ * @since 3.5.0
  */
 public class SumLong implements Accumulation<Long, MutableLong, Long>
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopN.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopN.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopN.java
index c95cbb4..2121a33 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopN.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopN.java
@@ -27,6 +27,8 @@ import org.apache.apex.malhar.lib.window.Accumulation;
 
 /**
  * TopN accumulation
+ *
+ * @since 3.5.0
  */
 public class TopN<T> implements Accumulation<T, List<T>, List<T>>
 {

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopNByKey.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopNByKey.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopNByKey.java
index 92a6eb6..ea79ed2 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopNByKey.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/TopNByKey.java
@@ -29,6 +29,8 @@ import com.datatorrent.lib.util.KeyValPair;
 
 /**
  * Generalized TopNByKey accumulation
+ *
+ * @since 3.5.0
  */
 public class TopNByKey<K, V> implements
     Accumulation<KeyValPair<K, V>, Map<K, V>, List<KeyValPair<K, V>>>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/impl/AbstractWindowedOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/AbstractWindowedOperator.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/AbstractWindowedOperator.java
index 354738d..7abe9b6 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/AbstractWindowedOperator.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/AbstractWindowedOperator.java
@@ -58,6 +58,8 @@ import com.datatorrent.common.util.BaseOperator;
  * @param <DataStorageT> The type of the data storage
  * @param <RetractionStorageT> The type of the retraction storage
  * @param <AccumulationT> The type of the accumulation
+ *
+ * @since 3.5.0
  */
 @InterfaceStability.Evolving
 public abstract class AbstractWindowedOperator<InputT, OutputT, DataStorageT extends WindowedStorage,
RetractionStorageT extends WindowedStorage, AccumulationT extends Accumulation>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedKeyedStorage.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedKeyedStorage.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedKeyedStorage.java
index 65cc595..7dbfbb1 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedKeyedStorage.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedKeyedStorage.java
@@ -37,6 +37,8 @@ import org.apache.hadoop.classification.InterfaceStability;
  * This is the in-memory implementation of {@link WindowedKeyedStorage}. Do not use this
class if you have a large state that
  * can't be fit in memory. Also, this class may go away soon as there are plans to incorporate
{@link Spillable} data structures
  * in the near future.
+ *
+ * @since 3.5.0
  */
 @InterfaceStability.Unstable
 public class InMemoryWindowedKeyedStorage<K, V> extends InMemoryWindowedStorage<Map<K,
V>>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedStorage.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedStorage.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedStorage.java
index a78a327..f6de894 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedStorage.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/InMemoryWindowedStorage.java
@@ -31,6 +31,8 @@ import org.apache.hadoop.classification.InterfaceStability;
  * This is the in-memory implementation of {@link WindowedStorage}. Do not use this class
if you have a large state that
  * can't be fit in memory. Also, this class may go away soon as there are plans to incorporate
{@link Spillable} data
  * structures in the near future.
+ *
+ * @since 3.5.0
  */
 @InterfaceStability.Unstable
 public class InMemoryWindowedStorage<T> implements WindowedStorage<T>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedOperatorImpl.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedOperatorImpl.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedOperatorImpl.java
index 2b71fc0..7077c96 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedOperatorImpl.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedOperatorImpl.java
@@ -43,6 +43,8 @@ import com.datatorrent.lib.util.KeyValPair;
  * @param <InputValT> The type of the value of the keyed input tuple
  * @param <AccumT> The type of the accumulated value in the operator state per key
per window
  * @param <OutputValT> The type of the value of the keyed output tuple
+ *
+ * @since 3.5.0
  */
 @InterfaceStability.Evolving
 public class KeyedWindowedOperatorImpl<KeyT, InputValT, AccumT, OutputValT>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WatermarkImpl.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WatermarkImpl.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WatermarkImpl.java
index 7dcd527..86fcd53 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WatermarkImpl.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WatermarkImpl.java
@@ -23,6 +23,8 @@ import org.apache.hadoop.classification.InterfaceStability;
 
 /**
  * The implementation of the Watermark tuple
+ *
+ * @since 3.5.0
  */
 @InterfaceStability.Evolving
 public class WatermarkImpl implements ControlTuple.Watermark

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedOperatorImpl.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedOperatorImpl.java
b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedOperatorImpl.java
index 1bee15d..d195004 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedOperatorImpl.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedOperatorImpl.java
@@ -31,6 +31,8 @@ import org.apache.hadoop.classification.InterfaceStability;
  * @param <InputT> The type of the value of the input tuple
  * @param <AccumT> The type of the accumulated value in the operator state per window
  * @param <OutputT> The type of the value of the output tuple
+ *
+ * @since 3.5.0
  */
 @InterfaceStability.Evolving
 public class WindowedOperatorImpl<InputT, AccumT, OutputT>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/stream/src/main/java/org/apache/apex/malhar/stream/api/CompositeStreamTransform.java
----------------------------------------------------------------------
diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/CompositeStreamTransform.java
b/stream/src/main/java/org/apache/apex/malhar/stream/api/CompositeStreamTransform.java
index 979f44f..b9a41a3 100644
--- a/stream/src/main/java/org/apache/apex/malhar/stream/api/CompositeStreamTransform.java
+++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/CompositeStreamTransform.java
@@ -22,6 +22,8 @@ import org.apache.hadoop.classification.InterfaceStability;
 
 /**
  * A group of Streams and transforms in between
+ *
+ * @since 3.5.0
  */
 @InterfaceStability.Evolving
 public abstract class CompositeStreamTransform<INSTREAM extends ApexStream, OUTSTREAM
extends ApexStream>

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/stream/src/main/java/org/apache/apex/malhar/stream/api/Option.java
----------------------------------------------------------------------
diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/Option.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/Option.java
index 1b8935f..6aa829e 100644
--- a/stream/src/main/java/org/apache/apex/malhar/stream/api/Option.java
+++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/Option.java
@@ -24,6 +24,8 @@ import com.datatorrent.api.Attribute;
 
 /**
  * Options for the operators in the dag
+ *
+ * @since 3.5.0
  */
 @InterfaceStability.Evolving
 public interface Option

http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/cdef9856/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/TupleWrapperOperator.java
----------------------------------------------------------------------
diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/TupleWrapperOperator.java
b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/TupleWrapperOperator.java
index 1bc500d..0ae36eb 100644
--- a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/TupleWrapperOperator.java
+++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/TupleWrapperOperator.java
@@ -32,6 +32,8 @@ import com.datatorrent.api.annotation.InputPortFieldAnnotation;
 
 /**
  * A wrapper operator that intercept the tuples and convert them between {@link Tuple}
+ *
+ * @since 3.5.0
  */
 public class TupleWrapperOperator implements InputOperator, Operator.CheckpointNotificationListener
 {


Mime
View raw message