Repository: incubator-apex-malhar Updated Branches: refs/heads/release-3.4 6f63ee2a8 -> 921dd0dee
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/library/src/main/java/org/apache/apex/malhar/lib/utils/IOUtils.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/IOUtils.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/IOUtils.java index 123e41a..b714698 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/IOUtils.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/IOUtils.java @@ -25,6 +25,9 @@ import java.io.OutputStream; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/** + * @since 3.4.0 + */ public class IOUtils { /** http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PassThruByteArraySerde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PassThruByteArraySerde.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PassThruByteArraySerde.java index 7d03634..85c34d9 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PassThruByteArraySerde.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PassThruByteArraySerde.java @@ -23,6 +23,8 @@ import org.apache.commons.lang3.mutable.MutableInt; /** * This is a simple pass through {@link Serde}. When serialization is performed the input byte array is returned. * Similarly when deserialization is performed the input byte array is returned. + * + * @since 3.4.0 */ public class PassThruByteArraySerde implements Serde<byte[], byte[]> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Serde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Serde.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Serde.java index df84c59..6e02aee 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Serde.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Serde.java @@ -24,6 +24,8 @@ import org.apache.commons.lang3.mutable.MutableInt; * This is an interface for a Serializer/Deserializer class. * @param <OBJ> The type of the object to Serialize and Deserialize. * @param <SER> The type to Serialize an Object to. + * + * @since 3.4.0 */ public interface Serde<OBJ, SER> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/library/src/main/java/org/apache/apex/malhar/lib/wal/FSWindowDataManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/wal/FSWindowDataManager.java b/library/src/main/java/org/apache/apex/malhar/lib/wal/FSWindowDataManager.java index b8ab2ce..3de6a1b 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/wal/FSWindowDataManager.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/wal/FSWindowDataManager.java @@ -45,6 +45,8 @@ import com.datatorrent.common.util.FSStorageAgent; /** * An {@link WindowDataManager} that uses FS to persist state. + * + * @since 3.4.0 */ public class FSWindowDataManager implements WindowDataManager { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/library/src/main/java/org/apache/apex/malhar/lib/wal/FileSystemWAL.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/wal/FileSystemWAL.java b/library/src/main/java/org/apache/apex/malhar/lib/wal/FileSystemWAL.java index 6edf204..f454188 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/wal/FileSystemWAL.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/wal/FileSystemWAL.java @@ -60,6 +60,8 @@ import com.datatorrent.netlet.util.Slice; * * Also this implementation is thread unsafe- the filesystem wal writer and reader operations should be performed in * operator's thread. + * + * @since 3.4.0 */ public class FileSystemWAL implements WAL<FileSystemWAL.FileSystemWALReader, FileSystemWAL.FileSystemWALWriter> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/library/src/main/java/org/apache/apex/malhar/lib/wal/WAL.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/wal/WAL.java b/library/src/main/java/org/apache/apex/malhar/lib/wal/WAL.java index 10d8359..45432d5 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/wal/WAL.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/wal/WAL.java @@ -30,6 +30,8 @@ import com.datatorrent.netlet.util.Slice; * * @param <READER> Type of WAL Reader * @param <WRITER> WAL Pointer Type. + * + * @since 3.4.0 */ public interface WAL<READER extends WAL.WALReader, WRITER extends WAL.WALWriter> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java index f97e8cc..2f65ba9 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/ApexStream.java @@ -34,6 +34,8 @@ import com.datatorrent.api.Operator; /** * The stream interface to build a DAG * @param <T> + * + * @since 3.4.0 */ public interface ApexStream<T> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/WindowedStream.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/WindowedStream.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/WindowedStream.java index a3bc846..748a76a 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/WindowedStream.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/WindowedStream.java @@ -48,6 +48,8 @@ package org.apache.apex.malhar.stream.api; * </p> * * @param <T> Output tuple type + * + * @since 3.4.0 */ public interface WindowedStream<T> extends ApexStream<T> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/function/Function.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/function/Function.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/function/Function.java index 1167744..f4e5e60 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/function/Function.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/function/Function.java @@ -20,6 +20,8 @@ package org.apache.apex.malhar.stream.api.function; /** * The top level function interface + * + * @since 3.4.0 */ public interface Function { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/ApexStreamImpl.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/ApexStreamImpl.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/ApexStreamImpl.java index 0e47727..2ff6d51 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/ApexStreamImpl.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/ApexStreamImpl.java @@ -46,6 +46,8 @@ import com.datatorrent.stram.plan.logical.LogicalPlan; /** * Default stream implementation for ApexStream interface. * It creates the dag(execution plan) from stream api + * + * @since 3.4.0 */ public class ApexStreamImpl<T> implements ApexStream<T> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/DagMeta.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/DagMeta.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/DagMeta.java index 15417b5..791ce3e 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/DagMeta.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/DagMeta.java @@ -38,6 +38,8 @@ import com.datatorrent.stram.plan.logical.LogicalPlan; /** * Graph data structure for DAG * With this data structure, the framework can do lazy load and optimization + * + * @since 3.4.0 */ public class DagMeta { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/IDGenerator.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/IDGenerator.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/IDGenerator.java index 36200f2..982980c 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/IDGenerator.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/IDGenerator.java @@ -26,6 +26,8 @@ import static java.lang.System.currentTimeMillis; /** * A util class to generate unique ids in dag + * + * @since 3.4.0 */ public class IDGenerator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/StreamFactory.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/StreamFactory.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/StreamFactory.java index 70a11b5..7af6ece 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/StreamFactory.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/impl/StreamFactory.java @@ -27,6 +27,8 @@ import com.datatorrent.contrib.kafka.KafkaSinglePortStringInputOperator; /** * A Factory class to build from different kind of input source + * + * @since 3.4.0 */ public class StreamFactory { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/AnnonymousClassModifier.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/AnnonymousClassModifier.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/AnnonymousClassModifier.java index 9628354..cc85f37 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/AnnonymousClassModifier.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/AnnonymousClassModifier.java @@ -30,6 +30,8 @@ import com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.Opcodes; * This class is used to modify the bytecode of annonymous at runtime. * The limit for this is the annonymous class that is being modified must by stateless * + * + * @since 3.4.0 */ public class AnnonymousClassModifier extends ClassVisitor { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/ByteArrayClassLoader.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/ByteArrayClassLoader.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/ByteArrayClassLoader.java index 61ec10b..9194dc2 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/ByteArrayClassLoader.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/ByteArrayClassLoader.java @@ -21,6 +21,9 @@ package org.apache.apex.malhar.stream.api.operator; import java.util.Map; +/** + * @since 3.4.0 + */ public class ByteArrayClassLoader extends ClassLoader { private final Map<String, byte[]> classes; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/FunctionOperator.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/FunctionOperator.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/FunctionOperator.java index 5f80062..0a8ba55 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/FunctionOperator.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/operator/FunctionOperator.java @@ -42,6 +42,8 @@ import com.datatorrent.api.Operator; /** * Operators that wrap the functions + * + * @since 3.4.0 */ public class FunctionOperator<OUT, FUNCTION extends Function> implements Operator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/util/KeyedTuple.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/util/KeyedTuple.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/util/KeyedTuple.java index 755521f..3641189 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/util/KeyedTuple.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/util/KeyedTuple.java @@ -21,6 +21,8 @@ package org.apache.apex.malhar.stream.api.util; /** * An interface indicate a tuple with a specific key * It is used internally to identify the key from the tuple + * + * @since 3.4.0 */ public interface KeyedTuple<K> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/aea89fa8/stream/src/main/java/org/apache/apex/malhar/stream/api/util/TupleUtil.java ---------------------------------------------------------------------- diff --git a/stream/src/main/java/org/apache/apex/malhar/stream/api/util/TupleUtil.java b/stream/src/main/java/org/apache/apex/malhar/stream/api/util/TupleUtil.java index f6c2552..583615a 100644 --- a/stream/src/main/java/org/apache/apex/malhar/stream/api/util/TupleUtil.java +++ b/stream/src/main/java/org/apache/apex/malhar/stream/api/util/TupleUtil.java @@ -23,6 +23,8 @@ package org.apache.apex.malhar.stream.api.util; * Or converting from data tuples to display tuples <br> * Or generating watermark tuples <br> * + * + * @since 3.4.0 */ public class TupleUtil {
