apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [2/2] incubator-apex-malhar git commit: APEXMALHAR-1950 #resolve #comment includes : 1. removed @Stable annotation from classes 2. add @Evolving to classes and packages
Date Fri, 08 Jan 2016 02:06:36 GMT
APEXMALHAR-1950 #resolve #comment includes :
1. removed @Stable annotation from classes
2. add @Evolving to classes and packages


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/d570b8d6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/d570b8d6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/d570b8d6

Branch: refs/heads/devel-3
Commit: d570b8d6f178a8c00da3819407bda3aa466b9821
Parents: b7199b7
Author: Chandni Singh <csingh@apache.org>
Authored: Wed Jan 6 18:30:23 2016 -0800
Committer: Chandni Singh <csingh@apache.org>
Committed: Thu Jan 7 14:42:40 2016 -0800

----------------------------------------------------------------------
 .../contrib/accumulo/package-info.java          | 20 +++++++++++++++++++
 .../contrib/aerospike/package-info.java         | 20 +++++++++++++++++++
 .../contrib/apachelog/package-info.java         |  1 +
 .../contrib/cassandra/package-info.java         | 20 +++++++++++++++++++
 .../contrib/couchbase/package-info.java         | 20 +++++++++++++++++++
 .../contrib/couchdb/package-info.java           | 20 +++++++++++++++++++
 .../contrib/elasticsearch/package-info.java     | 20 +++++++++++++++++++
 .../contrib/formatter/CsvFormatter.java         |  3 +--
 .../datatorrent/contrib/hbase/package-info.java |  7 ++++---
 .../datatorrent/contrib/hive/package-info.java  | 20 +++++++++++++++++++
 .../contrib/jython/package-info.java            | 20 +++++++++++++++++++
 .../datatorrent/contrib/kafka/package-info.java |  3 ---
 .../contrib/kinesis/package-info.java           | 20 +++++++++++++++++++
 .../contrib/memcache/package-info.java          |  7 ++++---
 .../contrib/memcache_whalin/package-info.java   |  7 ++++---
 .../contrib/memsql/package-info.java            | 20 +++++++++++++++++++
 .../contrib/mongodb/package-info.java           |  7 ++++---
 .../datatorrent/contrib/mqtt/package-info.java  |  1 +
 .../datatorrent/contrib/parser/CsvParser.java   |  3 ---
 .../contrib/parser/package-info.java            | 20 +++++++++++++++++++
 .../com/datatorrent/contrib/r/package-info.java | 20 +++++++++++++++++++
 .../contrib/rabbitmq/package-info.java          |  7 ++++---
 .../datatorrent/contrib/redis/package-info.java |  1 +
 .../contrib/romesyndication/package-info.java   |  7 ++++---
 .../datatorrent/contrib/ruby/RubyOperator.java  |  1 +
 .../datatorrent/contrib/solr/package-info.java  | 20 +++++++++++++++++++
 .../contrib/splunk/package-info.java            | 20 +++++++++++++++++++
 .../contrib/sqlite/package-info.java            |  7 ++++---
 .../contrib/twitter/TwitterSampleInput.java     |  1 +
 .../datatorrent/contrib/zmq/package-info.java   |  7 ++++---
 .../com/datatorrent/lib/algo/package-info.java  |  2 +-
 .../datatorrent/lib/appdata/package-info.java   | 20 +++++++++++++++++++
 .../com/datatorrent/lib/codec/package-info.java |  2 +-
 .../datatorrent/lib/converter/package-info.java | 20 +++++++++++++++++++
 .../datatorrent/lib/counters/package-info.java  |  3 ++-
 ...nsactionableKeyValueStoreOutputOperator.java |  1 +
 ...egateTransactionableStoreOutputOperator.java |  1 +
 ...BatchTransactionableStoreOutputOperator.java |  1 +
 .../db/AbstractKeyValueStoreInputOperator.java  |  1 +
 ...nsactionableKeyValueStoreOutputOperator.java |  1 +
 ...sThruTransactionableStoreOutputOperator.java |  1 +
 .../lib/db/AbstractStoreInputOperator.java      |  1 +
 .../lib/db/AbstractStoreOutputOperator.java     |  1 +
 ...tractTransactionableStoreOutputOperator.java |  1 +
 .../lib/db/TransactionableKeyValueStore.java    |  1 +
 .../datatorrent/lib/db/cache/package-info.java  | 20 +++++++++++++++++++
 .../lib/db/jdbc/AbstractJdbcInputOperator.java  |  1 +
 ...actJdbcNonTransactionableOutputOperator.java |  3 +--
 ...stractJdbcTransactionableOutputOperator.java |  3 ---
 .../db/jdbc/JDBCLookupCacheBackedOperator.java  |  1 +
 .../lib/db/jdbc/JdbcPOJOInputOperator.java      |  4 +---
 .../lib/db/jdbc/JdbcPOJOOutputOperator.java     |  4 +---
 .../com/datatorrent/lib/db/jdbc/JdbcStore.java  |  3 ---
 .../lib/db/jdbc/JdbcTransactionalStore.java     |  3 ---
 .../lib/dimensions/package-info.java            | 20 +++++++++++++++++++
 .../lib/fileaccess/package-info.java            | 20 +++++++++++++++++++
 .../datatorrent/lib/formatter/Formatter.java    |  4 +---
 .../lib/formatter/JsonFormatter.java            |  3 +--
 .../datatorrent/lib/formatter/XmlFormatter.java |  3 +--
 .../lib/io/AbstractFTPInputOperator.java        |  3 +--
 .../AbstractHttpGetMultiValuedMapOperator.java  |  1 +
 .../lib/io/AbstractHttpGetOperator.java         |  1 +
 .../lib/io/AbstractHttpInputOperator.java       |  1 +
 .../lib/io/AbstractHttpOperator.java            |  1 +
 .../io/AbstractKeyValueStoreOutputOperator.java |  1 +
 .../lib/io/AbstractSocketInputOperator.java     |  1 +
 .../datatorrent/lib/io/ApacheGenRandomLogs.java |  1 +
 .../CollectionMultiConsoleOutputOperator.java   |  1 +
 .../lib/io/ConsoleOutputOperator.java           |  1 +
 .../datatorrent/lib/io/HttpGetMapOperator.java  |  1 +
 .../lib/io/HttpJsonChunksInputOperator.java     |  1 +
 .../lib/io/HttpLinesInputOperator.java          |  1 +
 .../lib/io/HttpPostOutputOperator.java          |  1 +
 .../lib/io/MapMultiConsoleOutputOperator.java   |  1 +
 .../lib/io/PubSubWebSocketAppDataQuery.java     | 10 ++--------
 .../lib/io/PubSubWebSocketAppDataResult.java    |  3 ---
 .../lib/io/PubSubWebSocketInputOperator.java    |  3 ---
 .../lib/io/PubSubWebSocketOutputOperator.java   |  1 +
 .../lib/io/SimpleSinglePortInputOperator.java   |  1 +
 .../datatorrent/lib/io/SmtpOutputOperator.java  |  1 +
 .../lib/io/WebSocketInputOperator.java          | 21 ++++++++++----------
 .../lib/io/WebSocketOutputOperator.java         |  1 +
 .../lib/io/WebSocketServerInputOperator.java    |  1 +
 .../lib/io/WidgetOutputOperator.java            |  1 +
 .../lib/io/block/AbstractBlockReader.java       |  2 --
 .../lib/io/block/AbstractFSBlockReader.java     |  2 --
 .../datatorrent/lib/io/block/BlockMetadata.java |  3 ---
 .../datatorrent/lib/io/block/FSSliceReader.java |  3 ---
 .../datatorrent/lib/io/block/ReaderContext.java |  2 --
 .../lib/io/fs/AbstractFileInputOperator.java    |  2 --
 .../lib/io/fs/AbstractFileOutputOperator.java   |  2 --
 .../lib/io/fs/AbstractFileSplitter.java         |  1 +
 .../lib/io/fs/AbstractReconciler.java           |  4 +---
 .../io/fs/AbstractSingleFileOutputOperator.java |  3 ---
 .../fs/AbstractThroughputFileInputOperator.java |  1 +
 .../io/fs/AbstractWindowFileOutputOperator.java |  1 +
 .../datatorrent/lib/io/fs/FileSplitterBase.java |  2 --
 .../lib/io/fs/FileSplitterInput.java            |  2 --
 .../lib/io/fs/FilterStreamCodec.java            |  3 ---
 .../lib/io/fs/FilterStreamContext.java          |  3 ---
 .../lib/io/fs/FilterStreamProvider.java         |  3 ---
 .../lib/io/fs/TailFsInputOperator.java          |  1 +
 .../lib/io/jms/AbstractJMSInputOperator.java    |  2 --
 .../lib/io/jms/AbstractJMSOutputOperator.java   |  1 +
 .../AbstractJMSSinglePortOutputOperator.java    |  1 +
 .../io/jms/FSPsuedoTransactionableStore.java    |  1 +
 .../com/datatorrent/lib/io/jms/JMSBase.java     |  7 +++----
 .../lib/io/jms/JMSBaseTransactionableStore.java |  1 +
 .../lib/io/jms/JMSMultiPortOutputOperator.java  |  1 +
 .../lib/io/jms/JMSObjectInputOperator.java      |  1 +
 .../lib/io/jms/JMSStringInputOperator.java      |  1 +
 .../lib/io/jms/JMSTransactionableStore.java     |  1 +
 .../com/datatorrent/lib/logs/package-info.java  |  2 +-
 .../com/datatorrent/lib/math/package-info.java  |  2 +-
 .../datatorrent/lib/metric/package-info.java    |  3 ---
 .../lib/multiwindow/package-info.java           |  2 +-
 .../datatorrent/lib/parser/package-info.java    | 20 +++++++++++++++++++
 .../lib/partitioner/package-info.java           | 20 +++++++++++++++++++
 .../datatorrent/lib/script/package-info.java    |  2 +-
 .../lib/statistics/package-info.java            | 20 +++++++++++++++++++
 .../com/datatorrent/lib/stream/Counter.java     |  3 ---
 .../com/datatorrent/lib/stream/DevNull.java     |  3 ---
 .../datatorrent/lib/stream/package-info.java    |  2 +-
 .../lib/streamquery/package-info.java           |  2 +-
 .../datatorrent/lib/testbench/package-info.java |  2 +-
 .../com/datatorrent/lib/util/PojoUtils.java     |  2 --
 .../datatorrent/lib/util/WindowDataManager.java |  2 --
 .../lib/util/comparator/SliceComparator.java    |  2 --
 .../com/datatorrent/lib/util/package-info.java  |  7 ++++---
 .../lib/xml/AbstractXmlDOMOperator.java         |  1 +
 .../hadoop/io/file/tfile/CacheManager.java      |  3 ---
 .../hadoop/io/file/tfile/package-info.java      | 20 +++++++++++++++++++
 pom.xml                                         |  9 ++++-----
 133 files changed, 585 insertions(+), 160 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/accumulo/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/accumulo/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/accumulo/package-info.java
new file mode 100644
index 0000000..cbac406
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/accumulo/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.accumulo;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/aerospike/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/aerospike/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/aerospike/package-info.java
new file mode 100644
index 0000000..97e878c
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/aerospike/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.aerospike;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java
index 2dd995b..d99c7b5 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java
@@ -19,4 +19,5 @@
 /**
  * Apache log application, operators, and utilities.
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.apachelog;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/cassandra/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/package-info.java
new file mode 100644
index 0000000..1baae5e
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.cassandra;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/couchbase/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/couchbase/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/couchbase/package-info.java
new file mode 100644
index 0000000..1a6d05b
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/couchbase/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.couchbase;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/couchdb/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/couchdb/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/couchdb/package-info.java
new file mode 100644
index 0000000..be6ec34
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/couchdb/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.couchdb;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/elasticsearch/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/elasticsearch/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/elasticsearch/package-info.java
new file mode 100644
index 0000000..d89d53f
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/elasticsearch/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.elasticsearch;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java b/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java
index 78a7c78..4b4bae3 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java
@@ -33,7 +33,6 @@ import org.supercsv.exception.SuperCsvException;
 import org.supercsv.io.CsvBeanWriter;
 import org.supercsv.io.ICsvBeanWriter;
 import org.supercsv.prefs.CsvPreference;
-import org.apache.hadoop.classification.InterfaceStability;
 
 import com.datatorrent.api.Context;
 import com.datatorrent.lib.formatter.Formatter;
@@ -55,7 +54,7 @@ import com.datatorrent.netlet.util.DTThrowable;
  * @tags pojo csv formatter
  * @since 3.2.0
  */
-@InterfaceStability.Evolving
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class CsvFormatter extends Formatter<String>
 {
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java
index 4ef8da9..41c15d1 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java
@@ -16,7 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-/**
- * HBase operators and utilities.
- */
+/**
+ * HBase operators and utilities.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.hbase;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/hive/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/hive/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/hive/package-info.java
new file mode 100644
index 0000000..ad93d8f
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/hive/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.hive;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/jython/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/jython/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/jython/package-info.java
new file mode 100644
index 0000000..08b3a3e
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/jython/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.jython;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java
index 6cc91af..ea25951 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java
@@ -19,7 +19,4 @@
 /**
  * Kafka operators and utilities.
  */
-@InterfaceStability.Stable
 package com.datatorrent.contrib.kafka;
-
-import org.apache.hadoop.classification.InterfaceStability;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/kinesis/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/kinesis/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/kinesis/package-info.java
new file mode 100644
index 0000000..72a273c
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/kinesis/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.kinesis;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java
index 6137e2a..599d342 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java
@@ -16,7 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-/**
- * Memcache operators and utilities.
- */
+/**
+ * Memcache operators and utilities.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.memcache;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java
index 68f03ce..ab35817 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java
@@ -16,7 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-/**
- * Memcache operators and utilities using whalin library.
- */
+/**
+ * Memcache operators and utilities using whalin library.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.memcache_whalin;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/memsql/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/memsql/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/memsql/package-info.java
new file mode 100644
index 0000000..a23b118
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/memsql/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.memsql;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java
index 6855353..05797ff 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java
@@ -16,7 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-/**
- * MongoDB operators and utilities.
- */
+/**
+ * MongoDB operators and utilities.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.mongodb;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java
index 5286aa1..0c94e16 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java
@@ -19,4 +19,5 @@
 /**
  * MQTT operators and utilities.
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.mqtt;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java b/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java
index ada368c..af1eebe 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java
@@ -35,9 +35,7 @@ import org.supercsv.cellprocessor.ParseLong;
 import org.supercsv.cellprocessor.ift.CellProcessor;
 import org.supercsv.io.CsvBeanReader;
 import org.supercsv.prefs.CsvPreference;
-import org.apache.hadoop.classification.InterfaceStability;
 
-import com.datatorrent.api.Context;
 import com.datatorrent.api.Context.OperatorContext;
 import com.datatorrent.lib.parser.Parser;
 import com.datatorrent.lib.util.ReusableStringReader;
@@ -61,7 +59,6 @@ import com.datatorrent.netlet.util.DTThrowable;
  * @tags csv pojo parser
  * @since 3.2.0
  */
-@InterfaceStability.Evolving
 public class CsvParser extends Parser<String, String>
 {
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/parser/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/parser/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/parser/package-info.java
new file mode 100644
index 0000000..cb54b65
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/parser/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.parser;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/r/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/r/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/r/package-info.java
new file mode 100644
index 0000000..4c0730c
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/r/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.r;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java
index e201b51..4da2d04 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java
@@ -16,7 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-/**
- * RabbitMQ operators and utilities.
- */
+/**
+ * RabbitMQ operators and utilities.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.rabbitmq;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java
index 30a181e..d2f7a91 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java
@@ -19,4 +19,5 @@
 /**
  * Redis operators and utilities.
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.redis;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java
index bc252f1..b95c482 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java
@@ -16,7 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-/**
- * Rome operators and utilities.
- */
+/**
+ * Rome operators and utilities.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.romesyndication;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java b/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java
index 8d01879..bfb9e83 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java
@@ -40,6 +40,7 @@ import com.datatorrent.lib.script.ScriptOperator;
  * @tags script, map, string
  * @since 1.0.4
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class RubyOperator extends ScriptOperator {
 
   public enum Type

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/solr/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/solr/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/solr/package-info.java
new file mode 100644
index 0000000..5ebbbf7
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/solr/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.solr;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/splunk/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/splunk/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/splunk/package-info.java
new file mode 100644
index 0000000..610ee3b
--- /dev/null
+++ b/contrib/src/main/java/com/datatorrent/contrib/splunk/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.contrib.splunk;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java
index 762662d..469c4a1 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java
@@ -16,7 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-/**
- * SQLite operators and utilities.
- */
+/**
+ * SQLite operators and utilities.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.sqlite;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java b/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java
index b08daf5..1fa9b37 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java
@@ -50,6 +50,7 @@ import com.datatorrent.api.Operator.ActivationListener;
  * @tags input operator
  * @since 0.3.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class TwitterSampleInput implements InputOperator, ActivationListener<OperatorContext>, StatusListener
 {
   /**

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java
index dddd566..1ab0099 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java
@@ -16,7 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-/**
- * ZeroMQ operators and utilities.
- */
+/**
+ * ZeroMQ operators and utilities.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.contrib.zmq;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/algo/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/algo/package-info.java b/library/src/main/java/com/datatorrent/lib/algo/package-info.java
index 30a49c4..d368186 100644
--- a/library/src/main/java/com/datatorrent/lib/algo/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/algo/package-info.java
@@ -19,5 +19,5 @@
 /**
  * Library of algorithmic operators
  */
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.lib.algo;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/appdata/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/package-info.java b/library/src/main/java/com/datatorrent/lib/appdata/package-info.java
new file mode 100644
index 0000000..3218464
--- /dev/null
+++ b/library/src/main/java/com/datatorrent/lib/appdata/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.lib.appdata;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/codec/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/codec/package-info.java b/library/src/main/java/com/datatorrent/lib/codec/package-info.java
index 08b2c56..ded8689 100644
--- a/library/src/main/java/com/datatorrent/lib/codec/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/codec/package-info.java
@@ -19,6 +19,6 @@
 /**
  *  Shared codec implementations. 
  */
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 package com.datatorrent.lib.codec;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/converter/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/converter/package-info.java b/library/src/main/java/com/datatorrent/lib/converter/package-info.java
new file mode 100644
index 0000000..77429e9
--- /dev/null
+++ b/library/src/main/java/com/datatorrent/lib/converter/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.lib.converter;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/counters/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/counters/package-info.java b/library/src/main/java/com/datatorrent/lib/counters/package-info.java
index 6d8286f..c8ea286 100644
--- a/library/src/main/java/com/datatorrent/lib/counters/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/counters/package-info.java
@@ -19,4 +19,5 @@
 /**
  * Basic counters and aggregates implementations.
  */
-package com.datatorrent.lib.counters;
\ No newline at end of file
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.lib.counters;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java
index f485dd8..ba89f7b 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java
@@ -32,6 +32,7 @@ package com.datatorrent.lib.db;
  * @param <S> The store type.
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractAggregateTransactionableKeyValueStoreOutputOperator<T, S extends TransactionableKeyValueStore>
         extends AbstractAggregateTransactionableStoreOutputOperator<T, S>
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java
index 3ce9df5..f17dfb0 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java
@@ -32,6 +32,7 @@ package com.datatorrent.lib.db;
  * @param <S> The store type.
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractAggregateTransactionableStoreOutputOperator<T, S extends TransactionableStore> extends AbstractTransactionableStoreOutputOperator<T, S>
 {
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java
index 4714921..771e679 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java
@@ -34,6 +34,7 @@ import com.google.common.collect.Lists;
  * @param <S> The store type.
  * @since 1.0.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractBatchTransactionableStoreOutputOperator<T, S extends TransactionableStore> extends AbstractAggregateTransactionableStoreOutputOperator<T, S> {
 
   private Collection<T> tuples;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java
index 10407e9..9b6ddc2 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java
@@ -34,6 +34,7 @@ import java.util.*;
  * @param <S> The store type.
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractKeyValueStoreInputOperator<T, S extends KeyValueStore> extends AbstractStoreInputOperator<T, S>
 {
   protected List<Object> keys = new ArrayList<Object>();

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java
index 92627d6..f199986 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java
@@ -34,6 +34,7 @@ package com.datatorrent.lib.db;
  * @param <S> The store type
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractPassThruTransactionableKeyValueStoreOutputOperator<T, S extends TransactionableKeyValueStore>
         extends AbstractPassThruTransactionableStoreOutputOperator<T, S>
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java
index 025a4c3..55c8617 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java
@@ -34,6 +34,7 @@ package com.datatorrent.lib.db;
  * @param <S> The store type
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractPassThruTransactionableStoreOutputOperator<T, S extends TransactionableStore> extends AbstractTransactionableStoreOutputOperator<T, S>
 {
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java
index 21e1707..a6eb780 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java
@@ -35,6 +35,7 @@ import com.datatorrent.api.InputOperator;
  * @param <S> The store type
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractStoreInputOperator<T, S extends Connectable> implements InputOperator
 {
   /**

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java
index 4f864b6..aff5b3e 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java
@@ -38,6 +38,7 @@ import com.datatorrent.api.annotation.InputPortFieldAnnotation;
  * @param <S> The store type
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractStoreOutputOperator<T, S extends Connectable> extends BaseOperator
 {
   protected S store;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java
index 645855a..61682c2 100644
--- a/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java
@@ -43,6 +43,7 @@ import com.datatorrent.api.annotation.InputPortFieldAnnotation;
  * @param <S> The store type
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractTransactionableStoreOutputOperator<T, S extends TransactionableStore> extends BaseOperator
 {
   protected S store;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java b/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java
index 6264154..3263b87 100644
--- a/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java
+++ b/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java
@@ -23,6 +23,7 @@ package com.datatorrent.lib.db;
  *
  * @since 0.9.3
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public interface TransactionableKeyValueStore extends TransactionableStore, KeyValueStore
 {
 }

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/cache/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/cache/package-info.java b/library/src/main/java/com/datatorrent/lib/db/cache/package-info.java
new file mode 100644
index 0000000..efdfef3
--- /dev/null
+++ b/library/src/main/java/com/datatorrent/lib/db/cache/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.lib.db.cache;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java
index c473ce3..e63610f 100644
--- a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java
@@ -45,6 +45,7 @@ import com.datatorrent.lib.db.AbstractStoreInputOperator;
  * @param <T> The tuple type
  * @since 0.9.4
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractJdbcInputOperator<T> extends AbstractStoreInputOperator<T, JdbcStore>
 {
   private static final Logger logger = LoggerFactory.getLogger(AbstractJdbcInputOperator.class);

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java
index d776965..3de0376 100644
--- a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java
@@ -21,8 +21,6 @@ package com.datatorrent.lib.db.jdbc;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 
-
-
 import com.datatorrent.api.Context;
 import com.datatorrent.lib.db.AbstractStoreOutputOperator;
 
@@ -37,6 +35,7 @@ import com.datatorrent.lib.db.AbstractStoreOutputOperator;
  * @param <T> The kind of tuples that are being processed
  * @since 1.0.4
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractJdbcNonTransactionableOutputOperator<T, S extends JdbcStore> extends AbstractStoreOutputOperator<T, S>
 {
   protected transient PreparedStatement updateCommand;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java
index d59e231..77b76c1 100644
--- a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java
@@ -28,8 +28,6 @@ import javax.validation.constraints.NotNull;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import org.apache.hadoop.classification.InterfaceStability;
-
 import com.google.common.collect.Lists;
 
 import com.datatorrent.api.Context;
@@ -57,7 +55,6 @@ import com.datatorrent.lib.db.AbstractPassThruTransactionableStoreOutputOperator
  * @param <T> type of tuple
  * @since 0.9.4
  */
-@InterfaceStability.Stable
 public abstract class AbstractJdbcTransactionableOutputOperator<T>
     extends AbstractPassThruTransactionableStoreOutputOperator<T, JdbcTransactionalStore>
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java
index 7ca2ae1..b6a66a3 100644
--- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java
@@ -44,6 +44,7 @@ import com.datatorrent.lib.db.cache.AbstractDBLookupCacheBackedOperator;
  * @param <T> type of input tuples </T>
  * @since 0.9.1
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class JDBCLookupCacheBackedOperator<T> extends AbstractDBLookupCacheBackedOperator<T, JdbcStore>
 {
   @NotNull

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java
index 3568b62..8aea9b6 100644
--- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java
@@ -36,8 +36,6 @@ import javax.validation.constraints.NotNull;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import org.apache.hadoop.classification.InterfaceStability;
-
 import com.google.common.base.Preconditions;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
@@ -66,7 +64,7 @@ import com.datatorrent.lib.util.PojoUtils;
  * @tags database, sql, pojo, jdbc
  * @since 2.1.0
  */
-@InterfaceStability.Evolving
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class JdbcPOJOInputOperator extends AbstractJdbcInputOperator<Object>
     implements Operator.ActivationListener<Context.OperatorContext>
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 ffb4160..a7dcb2a 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
@@ -35,8 +35,6 @@ import javax.validation.constraints.NotNull;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import org.apache.hadoop.classification.InterfaceStability.Evolving;
-
 import com.google.common.collect.Lists;
 
 import com.datatorrent.api.Context;
@@ -64,7 +62,7 @@ import com.datatorrent.lib.util.PojoUtils.GetterShort;
  * @tags database, sql, pojo, jdbc
  * @since 2.1.0
  */
-@Evolving
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class JdbcPOJOOutputOperator extends AbstractJdbcTransactionableOutputOperator<Object>
     implements Operator.ActivationListener<OperatorContext>
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java
index 6af2b50..d9901aa 100644
--- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java
+++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java
@@ -28,8 +28,6 @@ import javax.validation.constraints.NotNull;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import org.apache.hadoop.classification.InterfaceStability;
-
 import com.google.common.base.CharMatcher;
 import com.google.common.base.Splitter;
 import com.google.common.collect.Iterables;
@@ -42,7 +40,6 @@ import com.datatorrent.netlet.util.DTThrowable;
  *
  * @since 0.9.4
  */
-@InterfaceStability.Stable
 public class JdbcStore implements Connectable
 {
   protected static final Logger logger = LoggerFactory.getLogger(JdbcStore.class);

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java
index 9d9266d..9bc18b0 100644
--- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java
+++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java
@@ -27,8 +27,6 @@ import javax.validation.constraints.NotNull;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import org.apache.hadoop.classification.InterfaceStability;
-
 import com.datatorrent.lib.db.TransactionableStore;
 
 /**
@@ -36,7 +34,6 @@ import com.datatorrent.lib.db.TransactionableStore;
  *
  * @since 0.9.4
  */
-@InterfaceStability.Stable
 public class JdbcTransactionalStore extends JdbcStore implements TransactionableStore
 {
   private static final transient Logger LOG = LoggerFactory.getLogger(JdbcTransactionalStore.class);

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/dimensions/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/dimensions/package-info.java b/library/src/main/java/com/datatorrent/lib/dimensions/package-info.java
new file mode 100644
index 0000000..4988df7
--- /dev/null
+++ b/library/src/main/java/com/datatorrent/lib/dimensions/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.lib.dimensions;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/fileaccess/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/fileaccess/package-info.java b/library/src/main/java/com/datatorrent/lib/fileaccess/package-info.java
new file mode 100644
index 0000000..8002459
--- /dev/null
+++ b/library/src/main/java/com/datatorrent/lib/fileaccess/package-info.java
@@ -0,0 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
+package com.datatorrent.lib.fileaccess;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java b/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java
index b7101fb..7d0018e 100644
--- a/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java
+++ b/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java
@@ -18,8 +18,6 @@
  */
 package com.datatorrent.lib.formatter;
 
-import org.apache.hadoop.classification.InterfaceStability;
-
 import com.datatorrent.api.Context;
 import com.datatorrent.api.Context.PortContext;
 import com.datatorrent.api.DefaultInputPort;
@@ -45,7 +43,7 @@ import com.datatorrent.lib.converter.Converter;
  * @param <INPUT>
  * @since 3.2.0
  */
-@InterfaceStability.Evolving
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class Formatter<OUTPUT> extends BaseOperator implements Converter<Object, OUTPUT>
 {
   protected transient Class<?> clazz;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java b/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java
index 4ed24b4..fa17fda 100644
--- a/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java
+++ b/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java
@@ -28,7 +28,6 @@ import org.codehaus.jackson.map.ObjectWriter;
 import org.codehaus.jackson.map.SerializationConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.apache.hadoop.classification.InterfaceStability;
 
 import com.datatorrent.api.Context.OperatorContext;
 import com.datatorrent.netlet.util.DTThrowable;
@@ -43,7 +42,7 @@ import com.datatorrent.netlet.util.DTThrowable;
  * @tags pojo json formatter
  * @since 3.2.0
  */
-@InterfaceStability.Evolving
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class JsonFormatter extends Formatter<String>
 {
   private transient ObjectWriter writer;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java b/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java
index 9ad2612..21a7b6a 100644
--- a/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java
+++ b/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java
@@ -28,7 +28,6 @@ import javax.xml.namespace.QName;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.apache.hadoop.classification.InterfaceStability;
 
 import com.datatorrent.api.Context.OperatorContext;
 import com.datatorrent.netlet.util.DTThrowable;
@@ -39,7 +38,7 @@ import com.datatorrent.netlet.util.DTThrowable;
  * @tags xml pojo formatter
  * @since 3.2.0
  */
-@InterfaceStability.Evolving
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class XmlFormatter extends Formatter<String>
 {
   protected String alias;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java
index c9f0604..1401100 100644
--- a/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java
@@ -31,7 +31,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import org.apache.commons.net.ftp.FTP;
-import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.fs.ftp.FTPFileSystem;
@@ -57,7 +56,7 @@ import com.datatorrent.lib.io.fs.AbstractFileInputOperator;
  *
  * @since 2.0.0
  */
-@InterfaceStability.Stable
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractFTPInputOperator<T> extends AbstractFileInputOperator<T>
 {
   @NotNull

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java
index 7a70deb..e3675a8 100644
--- a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java
@@ -35,6 +35,7 @@ import com.sun.jersey.api.client.WebResource;
  * @param <OUTPUT>
  * @since 1.0.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractHttpGetMultiValuedMapOperator<INPUT, OUTPUT> extends AbstractHttpGetOperator<INPUT, OUTPUT>
 {
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java
index e5ed969..fe9a50f 100644
--- a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java
@@ -40,6 +40,7 @@ import com.datatorrent.api.annotation.OutputPortFieldAnnotation;
  * @param <OUTPUT> tuple type of output port
  * @since 1.0.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractHttpGetOperator<INPUT, OUTPUT> extends AbstractHttpOperator<INPUT>
 {
   /**

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java
index e07013e..d7bb503 100644
--- a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java
@@ -44,6 +44,7 @@ import com.sun.jersey.api.client.WebResource;
  *
  * @since 0.3.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractHttpInputOperator<T> extends SimpleSinglePortInputOperator<T> implements Runnable
 {
   /**

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java
index 13dc01f..d5b8de6 100644
--- a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java
@@ -41,6 +41,7 @@ import com.datatorrent.api.DefaultInputPort;
  * @param <T>
  * @since 1.0.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractHttpOperator<T> extends BaseOperator
 {
   @NotNull

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java
index d2b011f..835f2a6 100644
--- a/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java
@@ -42,6 +42,7 @@ import com.datatorrent.lib.util.KeyValPair;
  *
  * @since 0.3.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractKeyValueStoreOutputOperator<K, V> extends BaseOperator
 {
   private static final Logger LOG = LoggerFactory.getLogger(AbstractKeyValueStoreOutputOperator.class);

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java
index 571580f..4f1e3df 100644
--- a/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java
@@ -48,6 +48,7 @@ import com.datatorrent.api.Operator.ActivationListener;
  * @param <T>
  * @since 0.9.5
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public abstract class AbstractSocketInputOperator<T> implements InputOperator, ActivationListener<OperatorContext>
 {
   /* The host to which to connect */

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java b/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java
index 8c1be97..d1afc60 100644
--- a/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java
+++ b/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java
@@ -56,6 +56,7 @@ import com.datatorrent.api.Context.OperatorContext;
  *
  * @since 0.3.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class ApacheGenRandomLogs extends BaseOperator implements InputOperator
 {
 	/**

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java
index 3b2ff8e..1c142a4 100644
--- a/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java
@@ -42,6 +42,7 @@ import com.datatorrent.api.DefaultInputPort;
  *
  * @since 0.3.4
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class CollectionMultiConsoleOutputOperator<E> extends BaseOperator
 {
   private boolean debug = false;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java
index 93c99cc..5e72d3d 100644
--- a/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java
@@ -37,6 +37,7 @@ import org.slf4j.LoggerFactory;
  *
  * @since 0.3.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 @Stateless
 public class ConsoleOutputOperator extends BaseOperator
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java b/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java
index 9e846b2..07e28b8 100644
--- a/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java
@@ -38,6 +38,7 @@ import com.sun.jersey.api.client.WebResource;
  * @param <V> Type of value in input map tuple
  * @since 1.0.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class HttpGetMapOperator<K, V> extends AbstractHttpGetOperator<Map<K, V>, String>
 {
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java
index 14acfe3..ea1fc8d 100644
--- a/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java
@@ -47,6 +47,7 @@ import org.slf4j.LoggerFactory;
  *
  * @since 0.9.4
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class HttpJsonChunksInputOperator extends AbstractHttpInputOperator<Map<String, String>>
 {
   private static final Logger LOG = LoggerFactory.getLogger(HttpJsonChunksInputOperator.class);

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java
index 187a38c..a483df1 100644
--- a/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java
@@ -33,6 +33,7 @@ import java.io.InputStreamReader;
  *
  * @since 0.9.4
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class HttpLinesInputOperator extends AbstractHttpInputOperator<String>
 {
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java
index a613898..a69761c 100644
--- a/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java
@@ -41,6 +41,7 @@ import com.datatorrent.api.Context.OperatorContext;
  * @param <T>
  * @since 0.3.2
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class HttpPostOutputOperator<T> extends AbstractHttpOperator<T>
 {
   protected transient WebResource resource;

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java
index b4ba09a..c461163 100644
--- a/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java
@@ -41,6 +41,7 @@ import com.datatorrent.api.DefaultInputPort;
  *
  * @since 0.3.4
  */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
 public class MapMultiConsoleOutputOperator<K, V> extends BaseOperator
 {
   private boolean debug = false;



Mime
View raw message