Marked @since 3.0.0 tags
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/ff4bd7e6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/ff4bd7e6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/ff4bd7e6 Branch: refs/heads/master Commit: ff4bd7e677cfc81869b228057a5e47b7da8ade8d Parents: 27ede3b Author: DataTorrent CI <[email protected]> Authored: Sat Aug 1 02:05:30 2015 -0700 Committer: DataTorrent CI <[email protected]> Committed: Sat Aug 1 02:05:30 2015 -0700 ---------------------------------------------------------------------- .../datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java | 1 + .../datatorrent/contrib/couchbase/CouchBasePOJOInputOperator.java | 1 + .../datatorrent/contrib/couchbase/CouchbasePOJOSetOperator.java | 1 + .../com/datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java | 1 + .../java/com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java | 1 + .../java/com/datatorrent/contrib/hive/FSPojoToHiveOperator.java | 1 + .../contrib/kinesis/KinesisByteArrayOutputOperator.java | 1 + .../datatorrent/contrib/memcache/MemcachePOJOOutputOperator.java | 1 + .../com/datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java | 1 + .../com/datatorrent/contrib/rabbitmq/RabbitMQInputOperator.java | 1 + .../com/datatorrent/contrib/rabbitmq/RabbitMQOutputOperator.java | 1 + .../java/com/datatorrent/contrib/zmq/ZeroMQInputOperator.java | 1 + .../java/com/datatorrent/contrib/zmq/ZeroMQOutputOperator.java | 1 + library/src/main/java/com/datatorrent/lib/appdata/QueueUtils.java | 3 ++- .../lib/appdata/datastructs/CacheLRUSynchronousFlush.java | 1 + .../com/datatorrent/lib/appdata/datastructs/DimensionalTable.java | 1 + .../lib/appdata/datastructs/NOPCacheFlushListener.java | 1 + .../java/com/datatorrent/lib/appdata/gpo/GPOByteArrayList.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/gpo/GPOGetters.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/gpo/GPOMutable.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/gpo/GPOType.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/gpo/GPOUtils.java | 1 + library/src/main/java/com/datatorrent/lib/appdata/gpo/Serde.java | 1 + .../lib/appdata/query/AbstractWindowEndQueueManager.java | 1 + .../lib/appdata/query/AppDataWindowEndQueueManager.java | 1 + .../main/java/com/datatorrent/lib/appdata/query/QueryBundle.java | 1 + .../java/com/datatorrent/lib/appdata/query/QueryExecutor.java | 1 + .../datatorrent/lib/appdata/query/QueryManagerSynchronous.java | 1 + .../main/java/com/datatorrent/lib/appdata/query/QueueList.java | 1 + .../main/java/com/datatorrent/lib/appdata/query/QueueManager.java | 1 + .../com/datatorrent/lib/appdata/query/SimpleDoneQueueManager.java | 1 + .../com/datatorrent/lib/appdata/query/SimpleQueueManager.java | 1 + .../com/datatorrent/lib/appdata/query/WindowEndQueueManager.java | 1 + .../lib/appdata/query/serde/CustomMessageDeserializer.java | 1 + .../lib/appdata/query/serde/CustomMessageSerializer.java | 1 + .../lib/appdata/query/serde/CustomMessageValidator.java | 1 + .../lib/appdata/query/serde/DataQuerySnapshotDeserializer.java | 1 + .../lib/appdata/query/serde/DataQuerySnapshotValidator.java | 1 + .../lib/appdata/query/serde/DataResultSnapshotSerializer.java | 1 + .../lib/appdata/query/serde/MessageDeserializerFactory.java | 1 + .../lib/appdata/query/serde/MessageDeserializerInfo.java | 1 + .../lib/appdata/query/serde/MessageSerializerFactory.java | 1 + .../lib/appdata/query/serde/MessageSerializerInfo.java | 1 + .../java/com/datatorrent/lib/appdata/query/serde/MessageType.java | 1 + .../datatorrent/lib/appdata/query/serde/MessageValidatorInfo.java | 1 + .../lib/appdata/query/serde/SimpleDataDeserializer.java | 1 + .../datatorrent/lib/appdata/query/serde/SimpleDataSerializer.java | 1 + .../datatorrent/lib/appdata/query/serde/SimpleDataValidator.java | 1 + .../com/datatorrent/lib/appdata/schemas/DataQuerySnapshot.java | 1 + .../com/datatorrent/lib/appdata/schemas/DataResultSnapshot.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/schemas/Fields.java | 1 + .../com/datatorrent/lib/appdata/schemas/FieldsDescriptor.java | 1 + .../main/java/com/datatorrent/lib/appdata/schemas/JSONType.java | 1 + .../main/java/com/datatorrent/lib/appdata/schemas/Message.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/schemas/QRBase.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/schemas/Query.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/schemas/Result.java | 1 + .../java/com/datatorrent/lib/appdata/schemas/ResultFormatter.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/schemas/Schema.java | 1 + .../java/com/datatorrent/lib/appdata/schemas/SchemaQuery.java | 1 + .../java/com/datatorrent/lib/appdata/schemas/SchemaRegistry.java | 1 + .../datatorrent/lib/appdata/schemas/SchemaRegistryMultiple.java | 1 + .../com/datatorrent/lib/appdata/schemas/SchemaRegistrySingle.java | 1 + .../java/com/datatorrent/lib/appdata/schemas/SchemaResult.java | 1 + .../datatorrent/lib/appdata/schemas/SchemaResultSerializer.java | 1 + .../java/com/datatorrent/lib/appdata/schemas/SchemaUtils.java | 1 + .../java/com/datatorrent/lib/appdata/schemas/SnapshotSchema.java | 1 + .../main/java/com/datatorrent/lib/appdata/schemas/TimeBucket.java | 1 + .../src/main/java/com/datatorrent/lib/appdata/schemas/Type.java | 1 + .../lib/appdata/snapshot/AbstractAppDataSnapshotServer.java | 1 + .../lib/appdata/snapshot/AppDataSnapshotServerMap.java | 1 + .../lib/appdata/snapshot/AppDataSnapshotServerPOJO.java | 1 + .../datatorrent/lib/converter/MapToKeyHashValuePairConverter.java | 1 + .../com/datatorrent/lib/converter/MapToKeyValuePairConverter.java | 1 + .../lib/converter/StringValueToNumberConverterForMap.java | 1 + .../java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java | 1 + .../java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java | 1 + .../java/com/datatorrent/lib/io/WebSocketServerInputOperator.java | 3 ++- library/src/main/java/com/datatorrent/lib/util/FieldInfo.java | 3 ++- .../main/java/com/datatorrent/lib/util/FieldValueGenerator.java | 3 ++- library/src/main/java/com/datatorrent/lib/util/TableInfo.java | 3 ++- 81 files changed, 86 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java index 2ad85fe..9d8e356 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java @@ -46,6 +46,7 @@ import com.datatorrent.api.Context.OperatorContext; * @displayName Cassandra Input Operator * @category Input * @tags database, nosql, pojo, cassandra + * @since 3.0.0 */ @Evolving public class CassandraPOJOInputOperator extends AbstractCassandraInputOperator<Object> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchBasePOJOInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchBasePOJOInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchBasePOJOInputOperator.java index 16c9246..3c1dc4f 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchBasePOJOInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchBasePOJOInputOperator.java @@ -46,6 +46,7 @@ import com.datatorrent.api.Context.OperatorContext; * @displayName Couchbase Input Operator * @category Input * @tags database, nosql, pojo, couchbase + * @since 3.0.0 */ @Evolving public class CouchBasePOJOInputOperator extends AbstractStoreInputOperator<Object, CouchBaseStore> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchbasePOJOSetOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchbasePOJOSetOperator.java b/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchbasePOJOSetOperator.java index f21cd01..ef203cc 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchbasePOJOSetOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchbasePOJOSetOperator.java @@ -33,6 +33,7 @@ import com.datatorrent.lib.util.PojoUtils.Getter; * @displayName Couchbase Output Operator * @category Output * @tags database, nosql, pojo, couchbase + * @since 3.0.0 */ @Evolving public class CouchbasePOJOSetOperator extends AbstractCouchBaseSetOperator<Object> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java index b944594..d399179 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java @@ -50,6 +50,7 @@ import com.datatorrent.api.Context.OperatorContext; * @displayName CouchDb Input Operator * @category Input * @tags database, nosql, pojo, couchdb + * @since 3.0.0 */ @Evolving public class CouchDBPOJOInputOperator extends AbstractCouchDBInputOperator<Object> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java index c2de8fe..3df4ef5 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java @@ -31,6 +31,7 @@ import com.datatorrent.lib.util.TableInfo; * @displayName HBase Output Operator * @category Output * @tags database, nosql, pojo, hbase + * @since 3.0.0 */ @Evolving public class HBasePOJOPutOperator extends AbstractHBasePutOutputOperator<Object> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/hive/FSPojoToHiveOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/hive/FSPojoToHiveOperator.java b/contrib/src/main/java/com/datatorrent/contrib/hive/FSPojoToHiveOperator.java index 0fc891f..ca19da5 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/hive/FSPojoToHiveOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/hive/FSPojoToHiveOperator.java @@ -35,6 +35,7 @@ import java.sql.Date; * @displayName: FS To Hive Operator * @category Output * @tags fs, hive, database + * @since 3.0.0 */ public class FSPojoToHiveOperator extends AbstractFSRollingOutputOperator<Object> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/kinesis/KinesisByteArrayOutputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/kinesis/KinesisByteArrayOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/kinesis/KinesisByteArrayOutputOperator.java index 4e937a1..99c6f68 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/kinesis/KinesisByteArrayOutputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/kinesis/KinesisByteArrayOutputOperator.java @@ -24,6 +24,7 @@ import com.datatorrent.common.util.Pair; * @displayName Kinesis Put Output * @category Output * @tags Kinesis put, output operator, ByteArray + * @since 3.0.0 */ public class KinesisByteArrayOutputOperator extends AbstractKinesisOutputOperator<byte[], Pair<String, byte[]>> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/memcache/MemcachePOJOOutputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/memcache/MemcachePOJOOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/memcache/MemcachePOJOOutputOperator.java index 1514674..dca1543 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/memcache/MemcachePOJOOutputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/memcache/MemcachePOJOOutputOperator.java @@ -30,6 +30,7 @@ import com.datatorrent.lib.util.TableInfo; * @displayName Memcache Output Operator * @category Output * @tags pojo, memcache + * @since 3.0.0 */ @Evolving public class MemcachePOJOOutputOperator extends AbstractMemcacheOutputOperator< Object > http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java index 6fa8cf2..83d8115 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java @@ -52,6 +52,7 @@ import org.slf4j.LoggerFactory; * @displayName Memsql Input Operator * @category Input * @tags database, sql, pojo, memsql + * @since 3.0.0 */ @Evolving public class MemsqlPOJOInputOperator extends AbstractMemsqlInputOperator<Object> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQInputOperator.java index cf788f4..93bab0e 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQInputOperator.java @@ -23,6 +23,7 @@ package com.datatorrent.contrib.rabbitmq; * @category Messaging * @tags input operator, string * + * @since 3.0.0 */ public class RabbitMQInputOperator extends AbstractSinglePortRabbitMQInputOperator<byte[]> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQOutputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQOutputOperator.java index 098cc85..d0761a5 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQOutputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/RabbitMQOutputOperator.java @@ -30,6 +30,7 @@ import com.datatorrent.netlet.util.DTThrowable; * @category Messaging * @tags input operator, string * + * @since 3.0.0 */ public class RabbitMQOutputOperator extends AbstractSinglePortRabbitMQOutputOperator<byte[]> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQInputOperator.java index 54ac915..ded1d69 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQInputOperator.java @@ -23,6 +23,7 @@ package com.datatorrent.contrib.zmq; * @category Messaging * @tags input operator, string * + * @since 3.0.0 */ public class ZeroMQInputOperator extends AbstractSinglePortZeroMQInputOperator<byte[]> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQOutputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQOutputOperator.java index b8e2491..4fa0804 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQOutputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/zmq/ZeroMQOutputOperator.java @@ -23,6 +23,7 @@ package com.datatorrent.contrib.zmq; * @category Messaging * @tags input operator, string * + * @since 3.0.0 */ public class ZeroMQOutputOperator extends AbstractSinglePortZeroMQOutputOperator<byte[]>{ http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/QueueUtils.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/QueueUtils.java b/library/src/main/java/com/datatorrent/lib/appdata/QueueUtils.java index 3a469a6..49089e6 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/QueueUtils.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/QueueUtils.java @@ -19,7 +19,8 @@ public class QueueUtils { /** * This class should not be instantiated. - */ + * @since 3.0.0 + */ private QueueUtils() { //Do nothing http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/datastructs/CacheLRUSynchronousFlush.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/datastructs/CacheLRUSynchronousFlush.java b/library/src/main/java/com/datatorrent/lib/appdata/datastructs/CacheLRUSynchronousFlush.java index ce36514..750f0e0 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/datastructs/CacheLRUSynchronousFlush.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/datastructs/CacheLRUSynchronousFlush.java @@ -31,6 +31,7 @@ import com.google.common.collect.Sets; * This is an LRU cache. * @param <KEY> The type of keys in the cache. * @param <VALUE> The type of values in the cache. + * @since 3.0.0 */ public class CacheLRUSynchronousFlush<KEY, VALUE> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/datastructs/DimensionalTable.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/datastructs/DimensionalTable.java b/library/src/main/java/com/datatorrent/lib/appdata/datastructs/DimensionalTable.java index ee6008b..1d4398f 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/datastructs/DimensionalTable.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/datastructs/DimensionalTable.java @@ -81,6 +81,7 @@ import org.slf4j.LoggerFactory; * is a matching key, otherwise nothing is returned. * * @param <DATA> The type of the data payload. + * @since 3.0.0 */ public class DimensionalTable<DATA> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/datastructs/NOPCacheFlushListener.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/datastructs/NOPCacheFlushListener.java b/library/src/main/java/com/datatorrent/lib/appdata/datastructs/NOPCacheFlushListener.java index 4dcf940..fae3fa2 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/datastructs/NOPCacheFlushListener.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/datastructs/NOPCacheFlushListener.java @@ -21,6 +21,7 @@ import com.datatorrent.lib.appdata.datastructs.CacheLRUSynchronousFlush.CacheFlu * This is a listener which is called by {@link CacheLRUSynchronousFlush} when the cache is flushed. * @param <KEY> The type of keys in the cache. * @param <VALUE> The type of values in the cache. + * @since 3.0.0 */ public class NOPCacheFlushListener<KEY, VALUE> implements CacheFlushListener<KEY, VALUE> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOByteArrayList.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOByteArrayList.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOByteArrayList.java index ec693fb..40960f2 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOByteArrayList.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOByteArrayList.java @@ -26,6 +26,7 @@ import java.util.Iterator; /** * This is a helper class which stores primitive bytes in an array list. This is useful * for serialization and deserialization. + * @since 3.0.0 */ public class GPOByteArrayList extends ByteArrayList { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOGetters.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOGetters.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOGetters.java index 5a15308..dfb9690 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOGetters.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOGetters.java @@ -28,6 +28,7 @@ import com.datatorrent.lib.util.PojoUtils.GetterShort; /** * This is a helper class which is intended to be used for operators * which need to take POJOs as input and convert them into GPOMutable objects. + * @since 3.0.0 */ public class GPOGetters { /** http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOMutable.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOMutable.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOMutable.java index 3220b10..ba8bc3c 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOMutable.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOMutable.java @@ -30,6 +30,7 @@ import com.datatorrent.lib.appdata.schemas.Type; * Each field has a primitive value stored in a primitive array and a name. * Fields of a particular primitive type are stored in the same array. The order of fields * in the array is the same as the lexicographic ordering of the field names. + * @since 3.0.0 */ public class GPOMutable implements Serializable { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOType.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOType.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOType.java index b519a10..1bdd7c2 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOType.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOType.java @@ -35,6 +35,7 @@ import static com.datatorrent.lib.appdata.gpo.GPOUtils.*; /** * This is a helper class that reduces the need for switch statements in may utility method in {@link GPOUtils}. + * @since 3.0.0 */ abstract class GPOType { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOUtils.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOUtils.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOUtils.java index 341f39c..23220a9 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOUtils.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/GPOUtils.java @@ -51,6 +51,7 @@ import com.datatorrent.lib.util.PojoUtils.GetterShort; /** * This class holds utility methods for serializing and deserializing {@link GPOMutable} objects to/from bytes and JSON. * There are also utility methods for converting POJOs into GPOMutable objects. + * @since 3.0.0 */ public class GPOUtils { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/gpo/Serde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/gpo/Serde.java b/library/src/main/java/com/datatorrent/lib/appdata/gpo/Serde.java index 57e5c77..3d1b0c7 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/gpo/Serde.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/gpo/Serde.java @@ -24,6 +24,7 @@ import org.apache.commons.lang3.mutable.MutableInt; * <p> * <b>Note: All the methods in this interface must be thread safe.</b> * </p> + * @since 3.0.0 */ public interface Serde { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/AbstractWindowEndQueueManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/AbstractWindowEndQueueManager.java b/library/src/main/java/com/datatorrent/lib/appdata/query/AbstractWindowEndQueueManager.java index 11a8236..8b6301e 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/AbstractWindowEndQueueManager.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/AbstractWindowEndQueueManager.java @@ -42,6 +42,7 @@ import com.datatorrent.api.Context.OperatorContext; * @param <QUERY_TYPE> The type of the query. * @param <META_QUERY> The type of any metadata associated with the query. * @param <QUEUE_CONTEXT> The type of the context used to manage the queueing of the query. + * @since 3.0.0 */ public abstract class AbstractWindowEndQueueManager<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT> implements QueueManager<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/AppDataWindowEndQueueManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/AppDataWindowEndQueueManager.java b/library/src/main/java/com/datatorrent/lib/appdata/query/AppDataWindowEndQueueManager.java index e31786e..1197d90 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/AppDataWindowEndQueueManager.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/AppDataWindowEndQueueManager.java @@ -29,6 +29,7 @@ import com.datatorrent.lib.appdata.schemas.Query; * the same query id as an existing query in the queue, the existing query is replaced with the new query. * @param <QUERY> The type of queries kept in the queue. * @param <META_QUERY> The type of query meta data kept in the queue. + * @since 3.0.0 */ public class AppDataWindowEndQueueManager<QUERY extends Query, META_QUERY> extends WindowEndQueueManager<QUERY, META_QUERY> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/QueryBundle.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/QueryBundle.java b/library/src/main/java/com/datatorrent/lib/appdata/query/QueryBundle.java index 942e65d..8799320 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/QueryBundle.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/QueryBundle.java @@ -21,6 +21,7 @@ package com.datatorrent.lib.appdata.query; * @param <QUERY_TYPE> The type of the query. * @param <META_QUERY> The type of any meta data to be included with the query. * @param <QUEUE_CONTEXT> The context associated with the query when it was enqueued. + * @since 3.0.0 */ public class QueryBundle<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/QueryExecutor.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/QueryExecutor.java b/library/src/main/java/com/datatorrent/lib/appdata/query/QueryExecutor.java index 0455bf4..ebdc108 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/QueryExecutor.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/QueryExecutor.java @@ -22,6 +22,7 @@ package com.datatorrent.lib.appdata.query; * @param <META_QUERY> The type of any additional meta data associated with the query when it was enqueued. * @param <QUEUE_CONTEXT> The type of the queue context of the query. * @param <RESULT> The type of the query's result. + * @since 3.0.0 */ public interface QueryExecutor<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT, RESULT> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerSynchronous.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerSynchronous.java b/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerSynchronous.java index c6775a1..73e2bcf 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerSynchronous.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/QueryManagerSynchronous.java @@ -32,6 +32,7 @@ import com.datatorrent.api.Context.OperatorContext; * @param <META_QUERY> The type of any query meta data. * @param <QUEUE_CONTEXT> The type of any context information used by the queue. * @param <RESULT> The type of the result returned by the {@link QueryExecutor}. + * @since 3.0.0 */ public class QueryManagerSynchronous<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT, RESULT> implements Component<OperatorContext> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/QueueList.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/QueueList.java b/library/src/main/java/com/datatorrent/lib/appdata/query/QueueList.java index 4d73b28..31d60ac 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/QueueList.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/QueueList.java @@ -20,6 +20,7 @@ import com.google.common.base.Preconditions; /** * This is a doubly linked list to be used for queueing queries. * @param <T> The type of the data used for queueing + * @since 3.0.0 */ public class QueueList<T> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/QueueManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/QueueManager.java b/library/src/main/java/com/datatorrent/lib/appdata/query/QueueManager.java index 45287b8..5bd6741 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/QueueManager.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/QueueManager.java @@ -26,6 +26,7 @@ import com.datatorrent.api.Context.OperatorContext; * which a query is queued that is known when the query is queued. This queue context information could * be updated by the queue manager throughout the lifetime of the query to control things like how long * the query has been queued for. + * @since 3.0.0 */ public interface QueueManager<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT> extends Component<OperatorContext> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleDoneQueueManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleDoneQueueManager.java b/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleDoneQueueManager.java index 5469d04..16a528b 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleDoneQueueManager.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleDoneQueueManager.java @@ -26,6 +26,7 @@ import com.datatorrent.lib.appdata.query.QueueList.QueueListNode; * queue context is true, then the query is remove, if the queue context is false, then the query stays in the queue. * @param <QUERY_TYPE> The type of the queries that are enqueued in the queue. * @param <META_QUERY> The type of any meta data associated with the queries. + * @since 3.0.0 */ public class SimpleDoneQueueManager<QUERY_TYPE, META_QUERY> extends AbstractWindowEndQueueManager<QUERY_TYPE, META_QUERY, MutableBoolean> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleQueueManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleQueueManager.java b/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleQueueManager.java index 8c6da10..b1af15e 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleQueueManager.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/SimpleQueueManager.java @@ -28,6 +28,7 @@ import com.datatorrent.api.Context.OperatorContext; * @param <QUERY_TYPE> The type of the query to be enqueued in the queue. * @param <META_QUERY> The type of the meta data to be enqueued with the query. * @param <QUEUE_CONTEXT> The type of the queue context data. + * @since 3.0.0 */ public class SimpleQueueManager<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT> implements QueueManager<QUERY_TYPE, META_QUERY, QUEUE_CONTEXT> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/WindowEndQueueManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/WindowEndQueueManager.java b/library/src/main/java/com/datatorrent/lib/appdata/query/WindowEndQueueManager.java index 52c1a37..9bcaec4 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/WindowEndQueueManager.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/WindowEndQueueManager.java @@ -24,6 +24,7 @@ import com.datatorrent.lib.appdata.query.QueueList.QueueListNode; * a query's countdown reaches 0 it is removed from the queue. * @param <QUERY_TYPE> The type of queries to be queued. * @param <META_QUERY> The type of metadata to be associated with queued queries. + * @since 3.0.0 */ public class WindowEndQueueManager<QUERY_TYPE, META_QUERY> extends AbstractWindowEndQueueManager<QUERY_TYPE, META_QUERY, MutableLong> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageDeserializer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageDeserializer.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageDeserializer.java index a98ff85..7284aaf 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageDeserializer.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageDeserializer.java @@ -22,6 +22,7 @@ import com.datatorrent.lib.appdata.schemas.Message; /** * This is an interface for a message deserializer. Classes implementing this interface should have a public * no-arg constructor. + * @since 3.0.0 */ public interface CustomMessageDeserializer { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageSerializer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageSerializer.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageSerializer.java index d8996bf..7a191ab 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageSerializer.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageSerializer.java @@ -21,6 +21,7 @@ import com.datatorrent.lib.appdata.schemas.ResultFormatter; /** * This interface defines a Message serializer, which will be used to convert a result to JSON. Classes * implementing this interface should have a public no-arg constructor. + * @since 3.0.0 */ public interface CustomMessageSerializer { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageValidator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageValidator.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageValidator.java index efb3ed1..b0d4759 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageValidator.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/CustomMessageValidator.java @@ -20,6 +20,7 @@ import com.datatorrent.lib.appdata.schemas.Message; /** * This interface defines a validator which validates the state of deserialized messages. Classes * implementing this interface should have a public no-arg constructor. + * @since 3.0.0 */ public interface CustomMessageValidator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotDeserializer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotDeserializer.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotDeserializer.java index 9aec9b5..bdc761f 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotDeserializer.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotDeserializer.java @@ -36,6 +36,7 @@ import com.datatorrent.lib.appdata.schemas.SchemaUtils; /** * This class is a deserializer for {@link DataQuerySnapshot} objects. + * @since 3.0.0 */ public class DataQuerySnapshotDeserializer implements CustomMessageDeserializer { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotValidator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotValidator.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotValidator.java index 6891b1a..d13dcc4 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotValidator.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataQuerySnapshotValidator.java @@ -27,6 +27,7 @@ import com.datatorrent.lib.appdata.schemas.SnapshotSchema; /** * This class is a validator for {@link DataQuerySnapshot} objects. + * @since 3.0.0 */ public class DataQuerySnapshotValidator implements CustomMessageValidator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataResultSnapshotSerializer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataResultSnapshotSerializer.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataResultSnapshotSerializer.java index 08d90de..204ebd3 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataResultSnapshotSerializer.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/DataResultSnapshotSerializer.java @@ -30,6 +30,7 @@ import com.datatorrent.lib.appdata.schemas.ResultFormatter; /** * This class is used to serialize {@link DataResultSnapshot} objects. + * @since 3.0.0 */ public class DataResultSnapshotSerializer implements CustomMessageSerializer { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerFactory.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerFactory.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerFactory.java index cd12377..4686648 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerFactory.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerFactory.java @@ -50,6 +50,7 @@ import com.datatorrent.lib.appdata.schemas.Message; * } * </code> * </pre> + * @since 3.0.0 */ public class MessageDeserializerFactory { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerInfo.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerInfo.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerInfo.java index bf4a4f2..60e9cc3 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerInfo.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageDeserializerInfo.java @@ -23,6 +23,7 @@ import java.lang.annotation.Target; /** * This annotation is placed on a {@link Message} class and is used to specify the deserializer for that class. + * @since 3.0.0 */ @Documented @Target(ElementType.TYPE) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerFactory.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerFactory.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerFactory.java index aca10c3..893e84d 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerFactory.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerFactory.java @@ -56,6 +56,7 @@ import com.datatorrent.lib.appdata.schemas.ResultFormatter; * } * </code> * </pre> + * @since 3.0.0 */ public class MessageSerializerFactory { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerInfo.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerInfo.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerInfo.java index 6a15f15..e4a125d 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerInfo.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageSerializerInfo.java @@ -23,6 +23,7 @@ import java.lang.annotation.Target; /** * This annotation is used to specify a serializer for a {@link Message} class. + * @since 3.0.0 */ @Documented @Target(ElementType.TYPE) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageType.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageType.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageType.java index d1c6df1..c7a8299 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageType.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageType.java @@ -23,6 +23,7 @@ import java.lang.annotation.Target; /** * This is the annotation that specifies message types and should be placed on a {@link Message} class. + * @since 3.0.0 */ @Documented @Target(ElementType.TYPE) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageValidatorInfo.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageValidatorInfo.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageValidatorInfo.java index 3b482a6..ac80a91 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageValidatorInfo.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/MessageValidatorInfo.java @@ -24,6 +24,7 @@ import java.lang.annotation.Target; /** * This annotation specifies the validator used for a Message and should be placed on the {@link Message} * class. + * @since 3.0.0 */ @Documented @Target(ElementType.TYPE) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataDeserializer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataDeserializer.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataDeserializer.java index c5510de..88feeb2 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataDeserializer.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataDeserializer.java @@ -25,6 +25,7 @@ import com.datatorrent.lib.appdata.schemas.Message; /** * This is a simple Message deserializer which deserializes messages using Jackson. + * @since 3.0.0 */ public class SimpleDataDeserializer implements CustomMessageDeserializer { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataSerializer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataSerializer.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataSerializer.java index 3d2ba6b..b92e145 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataSerializer.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataSerializer.java @@ -24,6 +24,7 @@ import com.datatorrent.lib.appdata.schemas.ResultFormatter; /** * This is a simple message serializer, which serializes messages using Jackson. + * @since 3.0.0 */ public class SimpleDataSerializer implements CustomMessageSerializer { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataValidator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataValidator.java b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataValidator.java index ff457ea..e789999 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataValidator.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/query/serde/SimpleDataValidator.java @@ -23,6 +23,7 @@ import com.datatorrent.lib.appdata.schemas.Message; /** * This is a Message validator which validates deserialized Messages using java validation. + * @since 3.0.0 */ public class SimpleDataValidator implements CustomMessageValidator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataQuerySnapshot.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataQuerySnapshot.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataQuerySnapshot.java index 43b17ae..0943172 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataQuerySnapshot.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataQuerySnapshot.java @@ -27,6 +27,7 @@ import com.datatorrent.lib.appdata.query.serde.MessageValidatorInfo; /** * This object represents queries issued against the {@link SnapshotSchema}. + * @since 3.0.0 */ @MessageType(type=DataQuerySnapshot.TYPE) @MessageDeserializerInfo(clazz=DataQuerySnapshotDeserializer.class) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataResultSnapshot.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataResultSnapshot.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataResultSnapshot.java index 1af0f44..1cb0258 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataResultSnapshot.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/DataResultSnapshot.java @@ -26,6 +26,7 @@ import com.datatorrent.lib.appdata.query.serde.MessageType; /** * This class represents the result sent in response to a {@link DataQuerySnapshot}. + * @since 3.0.0 */ @MessageType(type=DataResultSnapshot.TYPE) @MessageSerializerInfo(clazz=DataResultSnapshotSerializer.class) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/Fields.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Fields.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Fields.java index 5e9982a..b78331d 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Fields.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Fields.java @@ -32,6 +32,7 @@ import org.slf4j.LoggerFactory; * This is a somewhat vacuous class for managing field names for AppData schemas and queries. * Its function is to maintain a set of field names with no null values. It also maintains a list * of field names to increase iteration speed. + * @since 3.0.0 */ public class Fields implements Serializable { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/FieldsDescriptor.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/FieldsDescriptor.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/FieldsDescriptor.java index 2e4e29e..850e131 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/FieldsDescriptor.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/FieldsDescriptor.java @@ -41,6 +41,7 @@ import com.datatorrent.lib.appdata.gpo.SerdeObjectPayloadFix; * to map field names to values in order to respond to queries, it also serves as a schema which is * used in the serialization of {@link GPOMutable} objects in order to ensure consistent serialization * and deserialization of data. + * @since 3.0.0 */ public class FieldsDescriptor implements Serializable { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/JSONType.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/JSONType.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/JSONType.java index f5e613b..62d0d32 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/JSONType.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/JSONType.java @@ -17,6 +17,7 @@ package com.datatorrent.lib.appdata.schemas; /** * This is an enum type which contains entries for each unique JSONType. + * @since 3.0.0 */ public enum JSONType { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/Message.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Message.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Message.java index fcde2ba..e489c82 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Message.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Message.java @@ -32,6 +32,7 @@ import com.google.common.base.Preconditions; * <br/> * As can be seen above, the common element of an AppData message is a message type, which is what * this class encapsulates. + * @since 3.0.0 */ public abstract class Message { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/QRBase.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/QRBase.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/QRBase.java index 7e18e8a..9914767 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/QRBase.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/QRBase.java @@ -33,6 +33,7 @@ import com.google.common.base.Preconditions; * </ul> * * This base class holds the basic setters and getters for manipulating and storing these query properies. + * @since 3.0.0 */ public abstract class QRBase extends Message { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/Query.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Query.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Query.java index 1d5f73c..917a29e 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Query.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Query.java @@ -23,6 +23,7 @@ import com.google.common.collect.Maps; /** * This is a base class which represents the basic functionality of all AppData queries. + * @since 3.0.0 */ public abstract class Query extends QRBase { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/Result.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Result.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Result.java index 4e5901f..7b96d9b 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Result.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Result.java @@ -20,6 +20,7 @@ import com.google.common.base.Preconditions; /** * This class holds some boilerplate for setting and getting queries from result objects. All * query result objects should extend this class. + * @since 3.0.0 */ public abstract class Result extends QRBase { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/ResultFormatter.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/ResultFormatter.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/ResultFormatter.java index 6c58d62..b2ec5eb 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/ResultFormatter.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/ResultFormatter.java @@ -30,6 +30,7 @@ import java.text.DecimalFormat; * formatted a certain way and all float fields could potentially be formatted in another way. In the * future the result formatter will support formatting data uniquely for each individual field. * </p> + * @since 3.0.0 */ public class ResultFormatter implements Serializable { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/Schema.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Schema.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Schema.java index aaa6982..f5af058 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Schema.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Schema.java @@ -19,6 +19,7 @@ import java.util.Map; /** * This interface represents schemas such as: {@link DimensionalSchema} and {@link SnapShotSchema}. + * @since 3.0.0 */ public interface Schema { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaQuery.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaQuery.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaQuery.java index d3c7d29..f0c6f82 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaQuery.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaQuery.java @@ -28,6 +28,7 @@ import com.datatorrent.lib.appdata.query.serde.SimpleDataValidator; /** * This class represents a schema query. + * @since 3.0.0 */ @MessageType(type=SchemaQuery.TYPE) @MessageDeserializerInfo(clazz=SchemaQueryDeserializer.class) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistry.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistry.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistry.java index 567b75c..7947300 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistry.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistry.java @@ -21,6 +21,7 @@ import java.util.Map; * This interface describes a SchemaRegistry. A schema registry is used to store and look up * schemas for App Data enabled operators which serve data from multiple schemas. {@link SchemaRegistry}s * are primarily used to create responses to {@link SchemaQuery}s. + * @since 3.0.0 */ public interface SchemaRegistry { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistryMultiple.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistryMultiple.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistryMultiple.java index 969a84f..9833e94 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistryMultiple.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistryMultiple.java @@ -25,6 +25,7 @@ import com.datatorrent.lib.appdata.datastructs.DimensionalTable; /** * This class is a schema registry which can hold multiple schemas. It is intended to be * used in operators that serve multiple schemas. + * @since 3.0.0 */ public class SchemaRegistryMultiple implements SchemaRegistry, Serializable { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistrySingle.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistrySingle.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistrySingle.java index 233d6fd..4cb2567 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistrySingle.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaRegistrySingle.java @@ -27,6 +27,7 @@ import org.slf4j.LoggerFactory; /** * This schema registry holds a single schema. It is intended to be used in operators * which serve a single schema. + * @since 3.0.0 */ public class SchemaRegistrySingle implements SchemaRegistry, Serializable { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResult.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResult.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResult.java index b92a818..cbd52c9 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResult.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResult.java @@ -25,6 +25,7 @@ import com.datatorrent.lib.appdata.query.serde.MessageType; /** * This class represents a schema result, which will be serialized into JSON and sent * as a result to a {@link SchemaQuery}. + * @since 3.0.0 */ @MessageType(type=SchemaResult.TYPE) @MessageSerializerInfo(clazz=SchemaResultSerializer.class) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResultSerializer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResultSerializer.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResultSerializer.java index 0bd1f24..5b1c937 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResultSerializer.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaResultSerializer.java @@ -25,6 +25,7 @@ import com.datatorrent.lib.appdata.query.serde.CustomMessageSerializer; /** * This is the serializer class for {@link SchemaResult} objects. + * @since 3.0.0 */ public class SchemaResultSerializer implements CustomMessageSerializer { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaUtils.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaUtils.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaUtils.java index 6ac3883..dbd276c 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaUtils.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SchemaUtils.java @@ -38,6 +38,7 @@ import org.apache.commons.io.IOUtils; /** * This class holds utility methods for processing JSON. + * @since 3.0.0 */ public class SchemaUtils { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/SnapshotSchema.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SnapshotSchema.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SnapshotSchema.java index 05a52c7..9df0e22 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/SnapshotSchema.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/SnapshotSchema.java @@ -42,6 +42,7 @@ import com.datatorrent.netlet.util.DTThrowable; * <br/> * As can be seen above, the snapshot schema defines the name of each field which is served as well as * its type. + * @since 3.0.0 */ public class SnapshotSchema implements Schema { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/TimeBucket.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/TimeBucket.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/TimeBucket.java index 881f5fa..f2d2501 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/TimeBucket.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/TimeBucket.java @@ -42,6 +42,7 @@ import com.google.common.collect.Maps; * <li>q - quarter</li> * <li>y - year</li> * </ul> + * @since 3.0.0 */ public enum TimeBucket { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/schemas/Type.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Type.java b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Type.java index 67ea27d..00d7743 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/Type.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/Type.java @@ -28,6 +28,7 @@ import com.google.common.collect.Maps; /** * This enum is used to represent data types throughout AppData Framework. + * @since 3.0.0 */ public enum Type implements Serializable { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java b/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java index e43a83e..d0241d2 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java @@ -52,6 +52,7 @@ import com.datatorrent.common.experimental.AppData; * Additionally the list of input objects then need to be converted into {@link GPOMutable} objects * via an implementation of the {@link #convert} convert method. * @param <INPUT_EVENT> The type of the input events that the operator accepts. + * @since 3.0.0 */ public abstract class AbstractAppDataSnapshotServer<INPUT_EVENT> implements Operator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerMap.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerMap.java b/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerMap.java index 9bd71d1..dab2ca3 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerMap.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerMap.java @@ -34,6 +34,7 @@ import org.slf4j.LoggerFactory; * @displayName App Data Snapshot Map Server * @category DT View Integration * @tags app data, snapshot, map + * @since 3.0.0 */ public class AppDataSnapshotServerMap extends AbstractAppDataSnapshotServer<Map<String, Object>> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerPOJO.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerPOJO.java b/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerPOJO.java index df8a6ea..6b8b515 100644 --- a/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerPOJO.java +++ b/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AppDataSnapshotServerPOJO.java @@ -32,6 +32,7 @@ import com.datatorrent.lib.appdata.gpo.GPOUtils; * @displayName App Data Snapshot POJO Server * @category DT View Integration * @tags app data, snapshot, pojo + * @since 3.0.0 */ @Evolving public class AppDataSnapshotServerPOJO extends AbstractAppDataSnapshotServer<Object> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/converter/MapToKeyHashValuePairConverter.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/converter/MapToKeyHashValuePairConverter.java b/library/src/main/java/com/datatorrent/lib/converter/MapToKeyHashValuePairConverter.java index 95b6016..362fd12 100644 --- a/library/src/main/java/com/datatorrent/lib/converter/MapToKeyHashValuePairConverter.java +++ b/library/src/main/java/com/datatorrent/lib/converter/MapToKeyHashValuePairConverter.java @@ -31,6 +31,7 @@ import com.datatorrent.lib.util.KeyHashValPair; * @category Tuple Converters * @tags key value * + * @since 3.0.0 */ public class MapToKeyHashValuePairConverter<K, V> extends BaseOperator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/converter/MapToKeyValuePairConverter.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/converter/MapToKeyValuePairConverter.java b/library/src/main/java/com/datatorrent/lib/converter/MapToKeyValuePairConverter.java index 94f5fbd..34cad3b 100644 --- a/library/src/main/java/com/datatorrent/lib/converter/MapToKeyValuePairConverter.java +++ b/library/src/main/java/com/datatorrent/lib/converter/MapToKeyValuePairConverter.java @@ -32,6 +32,7 @@ import com.datatorrent.api.DefaultOutputPort; * @category Tuple Converters * @tags key value * + * @since 3.0.0 */ public class MapToKeyValuePairConverter<K, V> extends BaseOperator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/converter/StringValueToNumberConverterForMap.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/converter/StringValueToNumberConverterForMap.java b/library/src/main/java/com/datatorrent/lib/converter/StringValueToNumberConverterForMap.java index a5ca699..0897c1d 100644 --- a/library/src/main/java/com/datatorrent/lib/converter/StringValueToNumberConverterForMap.java +++ b/library/src/main/java/com/datatorrent/lib/converter/StringValueToNumberConverterForMap.java @@ -31,6 +31,7 @@ import com.datatorrent.api.DefaultOutputPort; * @category Tuple Converters * @tags string * + * @since 3.0.0 */ public class StringValueToNumberConverterForMap<K> extends BaseOperator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java index 81fb076..f2b1fdb 100644 --- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java +++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java @@ -34,6 +34,7 @@ import com.datatorrent.common.util.PubSubMessage; * @displayName App Data Pub Sub Query * @category DT View Integration * @tags input, app data, query + * @since 3.0.0 */ public class PubSubWebSocketAppDataQuery extends PubSubWebSocketInputOperator<String> implements AppData.ConnectionInfoProvider { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java index 12496a9..3401233 100644 --- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java +++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java @@ -33,6 +33,7 @@ import com.datatorrent.common.util.PubSubMessage.PubSubMessageType; * @displayName App Data Pub Sub Result * @category DT View Integration * @tags output, app data, result + * @since 3.0.0 */ @AppData.AppendQueryIdToTopic(value=true) public class PubSubWebSocketAppDataResult extends PubSubWebSocketOutputOperator<String> implements AppData.ConnectionInfoProvider http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java index f2aa0af..e50582d 100644 --- a/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java @@ -87,7 +87,8 @@ public abstract class WebSocketServerInputOperator implements InputOperator /** * @return the port - */ + * @since 3.0.0 + */ public int getPort() { return port; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/util/FieldInfo.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/util/FieldInfo.java b/library/src/main/java/com/datatorrent/lib/util/FieldInfo.java index 48a0c07..a4e4923 100644 --- a/library/src/main/java/com/datatorrent/lib/util/FieldInfo.java +++ b/library/src/main/java/com/datatorrent/lib/util/FieldInfo.java @@ -43,7 +43,8 @@ public class FieldInfo /** * the column name which keep this field. - */ + * @since 3.0.0 + */ public String getColumnName() { return columnName; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/util/FieldValueGenerator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/util/FieldValueGenerator.java b/library/src/main/java/com/datatorrent/lib/util/FieldValueGenerator.java index b0cf405..26c48d8 100644 --- a/library/src/main/java/com/datatorrent/lib/util/FieldValueGenerator.java +++ b/library/src/main/java/com/datatorrent/lib/util/FieldValueGenerator.java @@ -70,7 +70,8 @@ public class FieldValueGenerator<T extends FieldInfo> * @param obj * @param fieldValueHandler * @return - */ + * @since 3.0.0 + */ @SuppressWarnings({"rawtypes", "unchecked"}) public void handleFieldsValue(Object obj, FieldValueHandler fieldValueHandler) { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ff4bd7e6/library/src/main/java/com/datatorrent/lib/util/TableInfo.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/util/TableInfo.java b/library/src/main/java/com/datatorrent/lib/util/TableInfo.java index dac9adf..7b6729f 100644 --- a/library/src/main/java/com/datatorrent/lib/util/TableInfo.java +++ b/library/src/main/java/com/datatorrent/lib/util/TableInfo.java @@ -30,7 +30,8 @@ public class TableInfo< T extends FieldInfo > /** * expression for Row or Id - */ + * @since 3.0.0 + */ public String getRowOrIdExpression() { return rowOrIdExpression;
