apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [1/3] incubator-apex-malhar git commit: Add @since tags and update change log for release 3.4.0
Date Tue, 24 May 2016 16:52:31 GMT
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
 {


Mime
View raw message