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:31:55 UTC
[07/50] [abbrv] incubator-apex-malhar git commit: Mark POJO enabled
operators @Evolving
Mark POJO enabled operators @Evolving
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/fe2ba87d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/fe2ba87d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/fe2ba87d
Branch: refs/heads/master
Commit: fe2ba87db5536d5dd875697923b91cb28dbfd3a8
Parents: cecebb7
Author: thomas <th...@datatorrent.com>
Authored: Mon Jul 27 22:34:54 2015 -0700
Committer: thomas <th...@datatorrent.com>
Committed: Mon Jul 27 22:34:54 2015 -0700
----------------------------------------------------------------------
.../aerospike/AerospikePOJONonTransactionalPutOperator.java | 2 ++
.../aerospike/AerospikePOJOTransactionalPutOperator.java | 2 ++
.../contrib/cassandra/CassandraPOJOInputOperator.java | 3 ++-
.../contrib/cassandra/CassandraPOJOOutputOperator.java | 7 +++++--
.../contrib/couchbase/CouchBasePOJOInputOperator.java | 3 ++-
.../contrib/couchbase/CouchbasePOJOSetOperator.java | 2 ++
.../datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java | 3 ++-
.../contrib/couchdb/CouchDBPOJOOutputOperator.java | 3 +++
.../com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java | 3 ++-
.../com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java | 2 ++
.../contrib/memcache/MemcachePOJOOutputOperator.java | 3 +++
.../datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java | 5 +++++
.../datatorrent/contrib/memsql/MemsqlPOJOOutputOperator.java | 4 ++++
.../contrib/mongodb/MongoDBPOJOOutputOperator.java | 5 +++++
.../lib/appdata/snapshot/AppDataSnapshotServerPOJO.java | 4 +++-
.../com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java | 5 +++++
16 files changed, 49 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJONonTransactionalPutOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJONonTransactionalPutOperator.java b/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJONonTransactionalPutOperator.java
index 4b0a1f3..e9ea915 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJONonTransactionalPutOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJONonTransactionalPutOperator.java
@@ -23,6 +23,7 @@ import javax.validation.constraints.NotNull;
import com.aerospike.client.Bin;
import com.aerospike.client.Key;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -40,6 +41,7 @@ import com.datatorrent.lib.util.PojoUtils.Getter;
* @tags database, nosql, pojo, aerospike
* @since 2.1.0
*/
+@Evolving
public class AerospikePOJONonTransactionalPutOperator extends AbstractAerospikeNonTransactionalPutOperator<Object>
{
private static transient final Logger LOG
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJOTransactionalPutOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJOTransactionalPutOperator.java b/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJOTransactionalPutOperator.java
index 057d7b0..f2862bc 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJOTransactionalPutOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/aerospike/AerospikePOJOTransactionalPutOperator.java
@@ -23,6 +23,7 @@ import javax.validation.constraints.NotNull;
import com.aerospike.client.Bin;
import com.aerospike.client.Key;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -40,6 +41,7 @@ import com.datatorrent.lib.util.PojoUtils.Getter;
* @tags data, nosql, pojo, aerospike
* @since 2.1.0
*/
+@Evolving
public class AerospikePOJOTransactionalPutOperator
extends AbstractAerospikeTransactionalPutOperator<Object>
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/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 37c54d8..2ad85fe 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java
@@ -25,12 +25,12 @@ import com.datastax.driver.core.ColumnDefinitions;
import com.datastax.driver.core.DataType;
import com.datastax.driver.core.Row;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.datatorrent.lib.util.PojoUtils;
import com.datatorrent.lib.util.PojoUtils.*;
-
import com.datatorrent.api.Context.OperatorContext;
/**
@@ -47,6 +47,7 @@ import com.datatorrent.api.Context.OperatorContext;
* @category Input
* @tags database, nosql, pojo, cassandra
*/
+@Evolving
public class CassandraPOJOInputOperator extends AbstractCassandraInputOperator<Object>
{
@NotNull
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java
index 2b9d612..61ef26c 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOOutputOperator.java
@@ -16,8 +16,6 @@
package com.datatorrent.contrib.cassandra;
import com.datastax.driver.core.*;
-import com.datastax.driver.core.PreparedStatement;
-import com.datastax.driver.core.Statement;
import com.datastax.driver.core.exceptions.DriverException;
import com.datatorrent.lib.util.PojoUtils;
import com.datatorrent.lib.util.PojoUtils.GetterBoolean;
@@ -26,9 +24,13 @@ import com.datatorrent.lib.util.PojoUtils.GetterFloat;
import com.datatorrent.lib.util.PojoUtils.GetterInt;
import com.datatorrent.lib.util.PojoUtils.GetterLong;
import com.datatorrent.lib.util.PojoUtils.Getter;
+
import java.math.BigDecimal;
import java.util.*;
+
import javax.validation.constraints.NotNull;
+
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -42,6 +44,7 @@ import org.slf4j.LoggerFactory;
* @tags database, nosql, pojo, cassandra
* @since 2.1.0
*/
+@Evolving
public class CassandraPOJOOutputOperator extends AbstractCassandraTransactionableOutputOperatorPS<Object>
{
private static final long serialVersionUID = 201506181024L;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/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 305546b..16c9246 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchBasePOJOInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchBasePOJOInputOperator.java
@@ -23,10 +23,10 @@ import javax.validation.constraints.NotNull;
import com.couchbase.client.protocol.views.*;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.codehaus.jackson.map.ObjectMapper;
import com.datatorrent.lib.db.AbstractStoreInputOperator;
-
import com.datatorrent.api.Context.OperatorContext;
/**
@@ -47,6 +47,7 @@ import com.datatorrent.api.Context.OperatorContext;
* @category Input
* @tags database, nosql, pojo, couchbase
*/
+@Evolving
public class CouchBasePOJOInputOperator extends AbstractStoreInputOperator<Object, CouchBaseStore>
{
private transient Class<?> className = null;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/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 6809dd8..f21cd01 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchbasePOJOSetOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/couchbase/CouchbasePOJOSetOperator.java
@@ -19,6 +19,7 @@ import java.util.ArrayList;
import javax.validation.constraints.NotNull;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -33,6 +34,7 @@ import com.datatorrent.lib.util.PojoUtils.Getter;
* @category Output
* @tags database, nosql, pojo, couchbase
*/
+@Evolving
public class CouchbasePOJOSetOperator extends AbstractCouchBaseSetOperator<Object>
{
private static final Logger logger = LoggerFactory.getLogger(CouchBaseStore.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/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 c53b8ad..b944594 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOInputOperator.java
@@ -21,6 +21,7 @@ import java.util.List;
import javax.validation.constraints.NotNull;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.codehaus.jackson.JsonNode;
import org.codehaus.jackson.map.ObjectMapper;
import org.ektorp.ViewQuery;
@@ -28,7 +29,6 @@ import org.ektorp.ViewResult.Row;
import com.datatorrent.lib.util.PojoUtils;
import com.datatorrent.lib.util.PojoUtils.*;
-
import com.datatorrent.api.Context.OperatorContext;
/**
@@ -51,6 +51,7 @@ import com.datatorrent.api.Context.OperatorContext;
* @category Input
* @tags database, nosql, pojo, couchdb
*/
+@Evolving
public class CouchDBPOJOInputOperator extends AbstractCouchDBInputOperator<Object>
{
//List of expressions set by User. Example:setId(),setName(),Address
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOOutputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOOutputOperator.java
index f0c3e4c..2f47256 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOOutputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/couchdb/CouchDBPOJOOutputOperator.java
@@ -17,6 +17,8 @@ package com.datatorrent.contrib.couchdb;
import javax.validation.constraints.NotNull;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
+
import com.datatorrent.lib.util.PojoUtils;
import com.datatorrent.lib.util.PojoUtils.Getter;
@@ -28,6 +30,7 @@ import com.datatorrent.lib.util.PojoUtils.Getter;
* @tags database, nosql, pojo, couchdb
* @since 0.3.5
*/
+@Evolving
public class CouchDBPOJOOutputOperator extends AbstractCouchDBOutputOperator<Object>
{
private static final long serialVersionUID = 201506181121L;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
index f4696d5..9e5a46a 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
@@ -3,6 +3,7 @@ package com.datatorrent.contrib.hbase;
import java.io.IOException;
import java.util.List;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.client.Result;
@@ -15,7 +16,6 @@ import com.datatorrent.lib.util.FieldValueGenerator.ValueConverter;
import com.datatorrent.lib.util.PojoUtils;
import com.datatorrent.lib.util.PojoUtils.Setter;
import com.datatorrent.lib.util.TableInfo;
-
import com.datatorrent.api.Context.OperatorContext;
/**
@@ -23,6 +23,7 @@ import com.datatorrent.api.Context.OperatorContext;
* @category Input
* @tags database, nosql, pojo, hbase
*/
+@Evolving
public class HBasePOJOInputOperator extends HBaseInputOperator<Object>
{
private TableInfo<HBaseFieldInfo> tableInfo;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/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 8055456..c2de8fe 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOPutOperator.java
@@ -17,6 +17,7 @@ package com.datatorrent.contrib.hbase;
import java.util.List;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
@@ -31,6 +32,7 @@ import com.datatorrent.lib.util.TableInfo;
* @category Output
* @tags database, nosql, pojo, hbase
*/
+@Evolving
public class HBasePOJOPutOperator extends AbstractHBasePutOutputOperator<Object>
{
private static final long serialVersionUID = 3241368443399294019L;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/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 6e2c014..1514674 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/memcache/MemcachePOJOOutputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/memcache/MemcachePOJOOutputOperator.java
@@ -17,6 +17,8 @@ package com.datatorrent.contrib.memcache;
import java.util.List;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
+
import com.datatorrent.lib.util.FieldInfo;
import com.datatorrent.lib.util.FieldValueGenerator;
import com.datatorrent.lib.util.PojoUtils;
@@ -29,6 +31,7 @@ import com.datatorrent.lib.util.TableInfo;
* @category Output
* @tags pojo, memcache
*/
+@Evolving
public class MemcachePOJOOutputOperator extends AbstractMemcacheOutputOperator< Object >
{
private static final long serialVersionUID = 5290158463990158290L;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/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 6022c3d..6fa8cf2 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOInputOperator.java
@@ -24,14 +24,18 @@ import com.datatorrent.lib.util.PojoUtils.SetterFloat;
import com.datatorrent.lib.util.PojoUtils.SetterInt;
import com.datatorrent.lib.util.PojoUtils.SetterLong;
import com.datatorrent.lib.util.PojoUtils.SetterShort;
+
import java.math.BigDecimal;
import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+
import javax.validation.constraints.Min;
import javax.validation.constraints.NotNull;
+
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -49,6 +53,7 @@ import org.slf4j.LoggerFactory;
* @category Input
* @tags database, sql, pojo, memsql
*/
+@Evolving
public class MemsqlPOJOInputOperator extends AbstractMemsqlInputOperator<Object>
{
@Min(1)
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOOutputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOOutputOperator.java
index bba60f7..a3ab1f3 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOOutputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/memsql/MemsqlPOJOOutputOperator.java
@@ -28,7 +28,10 @@ import com.datatorrent.lib.util.PojoUtils.GetterShort;
import java.sql.*;
import java.util.ArrayList;
+
import javax.validation.constraints.NotNull;
+
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -42,6 +45,7 @@ import org.slf4j.LoggerFactory;
* @tags database, sql, pojo, memsql
*
*/
+@Evolving
public class MemsqlPOJOOutputOperator extends AbstractMemsqlOutputOperator<Object>
{
private static final long serialVersionUID = 20150618346L;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/contrib/src/main/java/com/datatorrent/contrib/mongodb/MongoDBPOJOOutputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/mongodb/MongoDBPOJOOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/mongodb/MongoDBPOJOOutputOperator.java
index 285ed90..fc56d73 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/mongodb/MongoDBPOJOOutputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/mongodb/MongoDBPOJOOutputOperator.java
@@ -18,11 +18,15 @@ package com.datatorrent.contrib.mongodb;
import com.datatorrent.lib.util.PojoUtils;
import com.datatorrent.lib.util.PojoUtils.Getter;
import com.mongodb.BasicDBObject;
+
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
+
import javax.validation.constraints.NotNull;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
+
/**
* Implementation of {@link MongoDBOutputOperator} that saves a POJO in the mongodb database. <br/>
* <p>
@@ -31,6 +35,7 @@ import javax.validation.constraints.NotNull;
* @tags database, nosql, pojo, mongodb
* @since 0.3.5
*/
+@Evolving
public class MongoDBPOJOOutputOperator extends MongoDBOutputOperator<Object>
{
private final transient ArrayList<Getter<Object, Object>> getterValues;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/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 0f87ec0..7f397ab 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
@@ -19,8 +19,9 @@ import java.util.Map;
import javax.validation.constraints.NotNull;
-import com.google.common.base.Preconditions;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
+import com.google.common.base.Preconditions;
import com.datatorrent.lib.appdata.gpo.GPOGetters;
import com.datatorrent.lib.appdata.gpo.GPOMutable;
import com.datatorrent.lib.appdata.gpo.GPOUtils;
@@ -32,6 +33,7 @@ import com.datatorrent.lib.appdata.gpo.GPOUtils;
* @category Output
* @tags app data, snapshot, pojo
*/
+@Evolving
public class AppDataSnapshotServerPOJO extends AbstractAppDataSnapshotServer<Object>
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/fe2ba87d/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java
index 4da989d..7451a50 100644
--- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java
@@ -25,9 +25,13 @@ import com.datatorrent.lib.util.PojoUtils.GetterFloat;
import com.datatorrent.lib.util.PojoUtils.GetterInt;
import com.datatorrent.lib.util.PojoUtils.GetterLong;
import com.datatorrent.lib.util.PojoUtils.GetterShort;
+
import java.sql.*;
import java.util.ArrayList;
+
import javax.validation.constraints.NotNull;
+
+import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -41,6 +45,7 @@ import org.slf4j.LoggerFactory;
* @tags database, sql, pojo, jdbc
* @since 2.1.0
*/
+@Evolving
public class JdbcPOJOOutputOperator extends AbstractJdbcTransactionableOutputOperator<Object>
{
@NotNull