You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:32:36 UTC
[48/50] [abbrv] incubator-apex-malhar git commit: Added missing
@since tags for new release
Added missing @since tags for new release
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/48d12cb4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/48d12cb4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/48d12cb4
Branch: refs/heads/master
Commit: 48d12cb426a7bcf5795036a24a57a3a6b3689eea
Parents: 8df703a
Author: DataTorrent CI <je...@datatorrent.com>
Authored: Tue Sep 1 04:16:21 2015 -0700
Committer: DataTorrent CI <je...@datatorrent.com>
Committed: Tue Sep 1 04:16:21 2015 -0700
----------------------------------------------------------------------
.../main/java/com/datatorrent/contrib/hbase/HBaseFieldInfo.java | 4 ++++
.../com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java | 1 +
.../datatorrent/contrib/redis/RedisKeyValueInputOperator.java | 2 ++
.../datatorrent/contrib/redis/RedisMapAsValueInputOperator.java | 1 +
.../com/datatorrent/contrib/redis/RedisPOJOInputOperator.java | 2 +-
.../com/datatorrent/contrib/redis/RedisPOJOOutputOperator.java | 1 +
.../com/datatorrent/lib/appdata/gpo/SerdeFieldsDescriptor.java | 4 ++++
.../com/datatorrent/lib/appdata/gpo/SerdeListGPOMutable.java | 4 ++++
.../com/datatorrent/lib/appdata/gpo/SerdeListPrimitive.java | 4 ++++
.../java/com/datatorrent/lib/appdata/gpo/SerdeListString.java | 4 ++++
.../com/datatorrent/lib/appdata/gpo/SerdeObjectPayloadFix.java | 4 ++++
.../datatorrent/lib/appdata/query/QueryManagerAsynchronous.java | 4 ++++
.../lib/appdata/query/serde/SchemaQueryDeserializer.java | 5 +++++
.../src/main/java/com/datatorrent/lib/metric/AvgAggregator.java | 4 ++++
.../com/datatorrent/lib/metric/max/DoubleMaxAggregator.java | 4 ++++
.../java/com/datatorrent/lib/metric/max/FloatMaxAggregator.java | 4 ++++
.../java/com/datatorrent/lib/metric/max/IntMaxAggregator.java | 4 ++++
.../java/com/datatorrent/lib/metric/max/LongMaxAggregator.java | 4 ++++
.../com/datatorrent/lib/metric/min/DoubleMinAggregator.java | 4 ++++
.../java/com/datatorrent/lib/metric/min/FloatMinAggregator.java | 4 ++++
.../java/com/datatorrent/lib/metric/min/IntMinAggregator.java | 4 ++++
.../java/com/datatorrent/lib/metric/min/LongMinAggregator.java | 4 ++++
22 files changed, 75 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/contrib/src/main/java/com/datatorrent/contrib/hbase/HBaseFieldInfo.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBaseFieldInfo.java b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBaseFieldInfo.java
index 614dffe..1cfcd98 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBaseFieldInfo.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBaseFieldInfo.java
@@ -19,6 +19,10 @@ import org.apache.hadoop.hbase.util.Bytes;
import com.datatorrent.lib.util.FieldInfo;
+/**
+ * @since 3.1.0
+ */
+
public class HBaseFieldInfo extends FieldInfo
{
private String familyName;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
index 9e5a46a..222f33a 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
@@ -22,6 +22,7 @@ import com.datatorrent.api.Context.OperatorContext;
* @displayName HBase Input Operator
* @category Input
* @tags database, nosql, pojo, hbase
+ * @since 3.1.0
*/
@Evolving
public class HBasePOJOInputOperator extends HBaseInputOperator<Object>
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/contrib/src/main/java/com/datatorrent/contrib/redis/RedisKeyValueInputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/redis/RedisKeyValueInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/redis/RedisKeyValueInputOperator.java
index 0d0efe8..bffdf69 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/redis/RedisKeyValueInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/redis/RedisKeyValueInputOperator.java
@@ -31,7 +31,9 @@ import com.datatorrent.lib.util.KeyValPair;
* @category Store
* @tags input operator, key value
*
+ * @since 3.1.0
*/
+
public class RedisKeyValueInputOperator extends AbstractRedisInputOperator<KeyValPair<String, String>>
{
private List<Object> keysObjectList = new ArrayList<Object>();
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/contrib/src/main/java/com/datatorrent/contrib/redis/RedisMapAsValueInputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/redis/RedisMapAsValueInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/redis/RedisMapAsValueInputOperator.java
index a7f0cd2..087f856 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/redis/RedisMapAsValueInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/redis/RedisMapAsValueInputOperator.java
@@ -27,6 +27,7 @@ import com.datatorrent.lib.util.KeyValPair;
* @displayName Redis Input Operator for Map
* @category Store
* @tags input operator, key value
+ * @since 3.1.0
*
*/
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOInputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOInputOperator.java
index ac3f7fc..20b464b 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOInputOperator.java
@@ -47,7 +47,7 @@ import com.datatorrent.netlet.util.DTThrowable;
* @displayName Redis POJO Input Operator
* @category Store
* @tags output operator, key value
- *
+ * @since 3.1.0
*/
@Evolving
public class RedisPOJOInputOperator extends AbstractRedisInputOperator<KeyValPair<String, Object>>
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOOutputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOOutputOperator.java
index 8966248..43309e7 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOOutputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/redis/RedisPOJOOutputOperator.java
@@ -42,6 +42,7 @@ import com.datatorrent.lib.util.PojoUtils.Getter;
* @displayName Redis POJO Output Operator
* @category Store
* @tags output operator, key value
+ * @since 3.1.0
*
*/
public class RedisPOJOOutputOperator extends AbstractRedisAggregateOutputOperator<KeyValPair<String, Object>>
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeFieldsDescriptor.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeFieldsDescriptor.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeFieldsDescriptor.java
index 50c5ff3..12fe837 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeFieldsDescriptor.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeFieldsDescriptor.java
@@ -24,6 +24,10 @@ import org.apache.commons.lang3.mutable.MutableInt;
import com.datatorrent.lib.appdata.schemas.FieldsDescriptor;
import com.datatorrent.lib.appdata.schemas.Type;
+/**
+ * @since 3.1.0
+ */
+
public class SerdeFieldsDescriptor implements Serde
{
public static final SerdeFieldsDescriptor INSTANCE = new SerdeFieldsDescriptor();
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListGPOMutable.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListGPOMutable.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListGPOMutable.java
index eafda27..4b1ea3b 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListGPOMutable.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListGPOMutable.java
@@ -24,6 +24,10 @@ import org.apache.commons.lang3.mutable.MutableInt;
import com.datatorrent.lib.appdata.schemas.FieldsDescriptor;
+/**
+ * @since 3.1.0
+ */
+
public class SerdeListGPOMutable implements Serde
{
public static final SerdeListGPOMutable INSTANCE = new SerdeListGPOMutable();
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListPrimitive.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListPrimitive.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListPrimitive.java
index 8a58565..5e21d6b 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListPrimitive.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListPrimitive.java
@@ -23,6 +23,10 @@ import org.apache.commons.lang3.mutable.MutableInt;
import com.datatorrent.lib.appdata.schemas.Type;
+/**
+ * @since 3.1.0
+ */
+
public class SerdeListPrimitive implements Serde
{
public static final SerdeListPrimitive INSTANCE = new SerdeListPrimitive();
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListString.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListString.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListString.java
index 519fbc2..4eedfc6 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListString.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeListString.java
@@ -24,6 +24,10 @@ import org.slf4j.LoggerFactory;
import org.apache.commons.lang3.mutable.MutableInt;
+/**
+ * @since 3.1.0
+ */
+
public class SerdeListString implements Serde
{
public static final SerdeListString INSTANCE = new SerdeListString();
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeObjectPayloadFix.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeObjectPayloadFix.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeObjectPayloadFix.java
index 42952f4..4a97e8c 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeObjectPayloadFix.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/SerdeObjectPayloadFix.java
@@ -15,6 +15,10 @@
*/
package com.datatorrent.lib.appdata.gpo;
+/**
+ * @since 3.1.0
+ */
+
public interface SerdeObjectPayloadFix
{
public void fix(Object[] objects);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerAsynchronous.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerAsynchronous.java b/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerAsynchronous.java
index cd54656..c6b9a5f 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerAsynchronous.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerAsynchronous.java
@@ -39,6 +39,10 @@ import com.datatorrent.api.Operator.IdleTimeHandler;
import com.datatorrent.common.util.NameableThreadFactory;
+/**
+ * @since 3.1.0
+ */
+
public class QueryManagerAsynchronous<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT, RESULT extends Result> implements Component<OperatorContext>, IdleTimeHandler
{
private DefaultOutputPort<String> resultPort = null;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SchemaQueryDeserializer.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SchemaQueryDeserializer.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SchemaQueryDeserializer.java
index a83d43f..467f362 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SchemaQueryDeserializer.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SchemaQueryDeserializer.java
@@ -28,6 +28,11 @@ import com.datatorrent.lib.appdata.schemas.Query;
import com.datatorrent.lib.appdata.schemas.SchemaQuery;
import com.datatorrent.lib.appdata.schemas.SchemaUtils;
+/**
+ * @since 3.1.0
+ */
+
+
public class SchemaQueryDeserializer implements CustomMessageDeserializer
{
@Override
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/AvgAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/AvgAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/AvgAggregator.java
index 99ef037..e764064 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/AvgAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/AvgAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("avg")
public class AvgAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/max/DoubleMaxAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/max/DoubleMaxAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/max/DoubleMaxAggregator.java
index c1734f4..b74a4ef 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/max/DoubleMaxAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/max/DoubleMaxAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("max")
public class DoubleMaxAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/max/FloatMaxAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/max/FloatMaxAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/max/FloatMaxAggregator.java
index 1c07e9f..499ca7e 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/max/FloatMaxAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/max/FloatMaxAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("max")
public class FloatMaxAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/max/IntMaxAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/max/IntMaxAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/max/IntMaxAggregator.java
index 3fa13be..b36bc6e 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/max/IntMaxAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/max/IntMaxAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("max")
public class IntMaxAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/max/LongMaxAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/max/LongMaxAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/max/LongMaxAggregator.java
index 4d47abf..5cd5ae3 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/max/LongMaxAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/max/LongMaxAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("max")
public class LongMaxAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/min/DoubleMinAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/min/DoubleMinAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/min/DoubleMinAggregator.java
index b6ee3ab..9ad5c8f 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/min/DoubleMinAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/min/DoubleMinAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("min")
public class DoubleMinAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/min/FloatMinAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/min/FloatMinAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/min/FloatMinAggregator.java
index 445d54b..9330720 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/min/FloatMinAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/min/FloatMinAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("min")
public class FloatMinAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/min/IntMinAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/min/IntMinAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/min/IntMinAggregator.java
index db4f45f..f285754 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/min/IntMinAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/min/IntMinAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("min")
public class IntMinAggregator implements SingleMetricAggregator, Serializable
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/48d12cb4/library/src/main/java/com/datatorrent/lib/metric/min/LongMinAggregator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/min/LongMinAggregator.java b/library/src/main/java/com/datatorrent/lib/metric/min/LongMinAggregator.java
index 16656d5..386151d 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/min/LongMinAggregator.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/min/LongMinAggregator.java
@@ -22,6 +22,10 @@ import com.datatorrent.api.annotation.Name;
import com.datatorrent.common.metric.SingleMetricAggregator;
+/**
+ * @since 3.1.0
+ */
+
@Name("min")
public class LongMinAggregator implements SingleMetricAggregator, Serializable
{