You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:32:10 UTC
[22/50] [abbrv] incubator-apex-malhar git commit: Marked @since 3.0.0
tags
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 <je...@datatorrent.com>
Authored: Sat Aug 1 02:05:30 2015 -0700
Committer: DataTorrent CI <je...@datatorrent.com>
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;