You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/08 03:06:36 UTC
[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
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 <cs...@apache.org>
Authored: Wed Jan 6 18:30:23 2016 -0800
Committer: Chandni Singh <cs...@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;