Repository: apex-malhar Updated Branches: refs/heads/master 61fb774dc -> 154ff3ccb
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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/681a84a8/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 {
