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 <[email protected]> Authored: Tue Sep 1 04:16:21 2015 -0700 Committer: DataTorrent CI <[email protected]> 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 {
