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 <[email protected]> Authored: Mon Jul 27 22:34:54 2015 -0700 Committer: thomas <[email protected]> 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
