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/29 20:12:46 UTC
[29/50] [abbrv] incubator-apex-malhar git commit: APEXMALHAR-1950
#resolve #comment marked classes that are frequently used as stable
APEXMALHAR-1950 #resolve #comment marked classes that are frequently used as stable
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/d88132ae
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/d88132ae
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/d88132ae
Branch: refs/heads/master
Commit: d88132ae5109aaeaa11ba5364d63618c93872215
Parents: ba8396f
Author: Chandni Singh <cs...@apache.org>
Authored: Wed Dec 16 14:21:37 2015 -0800
Committer: Chandni Singh <cs...@apache.org>
Committed: Tue Jan 5 23:34:51 2016 -0800
----------------------------------------------------------------------
.../java/com/datatorrent/contrib/kafka/package-info.java | 9 ++++++---
.../db/jdbc/AbstractJdbcTransactionableOutputOperator.java | 3 +++
.../main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java | 3 +++
.../com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java | 3 +++
.../com/datatorrent/lib/io/AbstractFTPInputOperator.java | 2 ++
.../com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java | 3 +++
.../datatorrent/lib/io/PubSubWebSocketAppDataResult.java | 4 ++++
.../datatorrent/lib/io/PubSubWebSocketInputOperator.java | 3 +++
.../java/com/datatorrent/lib/io/WebSocketInputOperator.java | 3 +++
.../com/datatorrent/lib/io/block/AbstractBlockReader.java | 3 ++-
.../com/datatorrent/lib/io/block/AbstractFSBlockReader.java | 2 ++
.../java/com/datatorrent/lib/io/block/BlockMetadata.java | 3 +++
.../java/com/datatorrent/lib/io/block/FSSliceReader.java | 3 +++
.../java/com/datatorrent/lib/io/block/ReaderContext.java | 2 ++
.../datatorrent/lib/io/fs/AbstractFileInputOperator.java | 2 ++
.../datatorrent/lib/io/fs/AbstractFileOutputOperator.java | 2 ++
.../java/com/datatorrent/lib/io/fs/AbstractReconciler.java | 3 +++
.../lib/io/fs/AbstractSingleFileOutputOperator.java | 3 +++
.../java/com/datatorrent/lib/io/fs/FileSplitterBase.java | 2 ++
.../java/com/datatorrent/lib/io/fs/FileSplitterInput.java | 2 ++
.../java/com/datatorrent/lib/io/fs/FilterStreamCodec.java | 3 +++
.../java/com/datatorrent/lib/io/fs/FilterStreamContext.java | 3 +++
.../com/datatorrent/lib/io/fs/FilterStreamProvider.java | 3 +++
.../datatorrent/lib/io/jms/AbstractJMSInputOperator.java | 2 ++
.../src/main/java/com/datatorrent/lib/io/jms/JMSBase.java | 3 +++
.../main/java/com/datatorrent/lib/metric/package-info.java | 3 +++
.../src/main/java/com/datatorrent/lib/stream/Counter.java | 3 +++
.../src/main/java/com/datatorrent/lib/stream/DevNull.java | 3 +++
.../src/main/java/com/datatorrent/lib/util/PojoUtils.java | 2 ++
.../datatorrent/lib/util/comparator/SliceComparator.java | 2 ++
30 files changed, 83 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/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 2939e33..6cc91af 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
@@ -16,7 +16,10 @@
* specific language governing permissions and limitations
* under the License.
*/
-/**
- * Kafka operators and utilities.
- */
+/**
+ * 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/d88132ae/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 77b76c1..d59e231 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,6 +28,8 @@ 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;
@@ -55,6 +57,7 @@ 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/d88132ae/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 d9901aa..6af2b50 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,6 +28,8 @@ 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;
@@ -40,6 +42,7 @@ 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/d88132ae/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 9bc18b0..9d9266d 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,6 +27,8 @@ 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;
/**
@@ -34,6 +36,7 @@ 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/d88132ae/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 d34f99b..c9f0604 100644
--- a/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java
@@ -31,6 +31,7 @@ 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;
@@ -56,6 +57,7 @@ import com.datatorrent.lib.io.fs.AbstractFileInputOperator;
*
* @since 2.0.0
*/
+@InterfaceStability.Stable
public abstract class AbstractFTPInputOperator<T> extends AbstractFileInputOperator<T>
{
@NotNull
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java
index fe7d579..cec366c 100644
--- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java
+++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java
@@ -30,6 +30,8 @@ import org.codehaus.jettison.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.apache.hadoop.classification.InterfaceStability;
+
import com.datatorrent.lib.appdata.StoreUtils.BufferingOutputPortFlusher;
import com.datatorrent.lib.appdata.query.WindowBoundedService;
@@ -50,6 +52,7 @@ import com.datatorrent.common.util.PubSubMessage;
* @tags input, app data, query
* @since 3.0.0
*/
+@InterfaceStability.Stable
public class PubSubWebSocketAppDataQuery extends PubSubWebSocketInputOperator<String> implements AppData.ConnectionInfoProvider, EmbeddableQueryInfoProvider<String>
{
private static final Logger logger = LoggerFactory.getLogger(PubSubWebSocketAppDataQuery.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java
index 7c5b798..c880cfe 100644
--- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java
+++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java
@@ -30,6 +30,9 @@ import com.datatorrent.api.Context.OperatorContext;
import com.datatorrent.common.experimental.AppData;
import com.datatorrent.common.util.PubSubMessage.PubSubMessageType;
import java.net.URI;
+
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* This is an app data pub sub result operator. This operator is used to send results to
* App Data dashboards produced by App Data store operators.
@@ -39,6 +42,7 @@ import java.net.URI;
* @tags output, app data, result
* @since 3.0.0
*/
+@InterfaceStability.Stable
@AppData.AppendQueryIdToTopic(value=true)
public class PubSubWebSocketAppDataResult extends PubSubWebSocketOutputOperator<String> implements AppData.ConnectionInfoProvider
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketInputOperator.java
index cdf2ee5..738fc5d 100644
--- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketInputOperator.java
@@ -27,6 +27,8 @@ import javax.validation.constraints.NotNull;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.apache.hadoop.classification.InterfaceStability;
+
import com.datatorrent.common.util.PubSubMessageCodec;
import com.datatorrent.common.util.PubSubWebSocketClient;
@@ -39,6 +41,7 @@ import com.datatorrent.common.util.PubSubWebSocketClient;
*
* @since 0.3.2
*/
+@InterfaceStability.Stable
public class PubSubWebSocketInputOperator<T> extends WebSocketInputOperator<T>
{
private static final Logger LOG = LoggerFactory.getLogger(PubSubWebSocketInputOperator.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
index fcd0398..e6ba6b9 100644
--- a/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
@@ -32,6 +32,8 @@ import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import javax.validation.constraints.NotNull;
import org.apache.commons.lang3.ClassUtils;
+import org.apache.hadoop.classification.InterfaceStability;
+
import org.codehaus.jackson.JsonFactory;
import org.codehaus.jackson.map.ObjectMapper;
import org.slf4j.Logger;
@@ -47,6 +49,7 @@ import org.slf4j.LoggerFactory;
*
* @since 0.3.2
*/
+@InterfaceStability.Stable
public class WebSocketInputOperator<T> extends SimpleSinglePortInputOperator<T> implements Runnable
{
private static final long serialVersionUID = 201506160829L;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/block/AbstractBlockReader.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/block/AbstractBlockReader.java b/library/src/main/java/com/datatorrent/lib/io/block/AbstractBlockReader.java
index aada298..fc624b6 100644
--- a/library/src/main/java/com/datatorrent/lib/io/block/AbstractBlockReader.java
+++ b/library/src/main/java/com/datatorrent/lib/io/block/AbstractBlockReader.java
@@ -34,6 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.commons.lang.mutable.MutableLong;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.fs.PositionedReadable;
import com.esotericsoftware.kryo.Kryo;
@@ -80,7 +81,7 @@ import com.datatorrent.lib.counters.BasicCounters;
*
* @since 2.1.0
*/
-
+@InterfaceStability.Stable
@StatsListener.DataQueueSize
public abstract class AbstractBlockReader<R, B extends BlockMetadata, STREAM extends InputStream & PositionedReadable>
extends BaseOperator
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/block/AbstractFSBlockReader.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/block/AbstractFSBlockReader.java b/library/src/main/java/com/datatorrent/lib/io/block/AbstractFSBlockReader.java
index d74c9c9..b083d73 100644
--- a/library/src/main/java/com/datatorrent/lib/io/block/AbstractFSBlockReader.java
+++ b/library/src/main/java/com/datatorrent/lib/io/block/AbstractFSBlockReader.java
@@ -20,6 +20,7 @@ package com.datatorrent.lib.io.block;
import java.io.IOException;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FileSystem;
@@ -35,6 +36,7 @@ import com.datatorrent.api.StatsListener;
*
* @since 2.1.0
*/
+@InterfaceStability.Stable
@StatsListener.DataQueueSize
public abstract class AbstractFSBlockReader<R>
extends AbstractBlockReader<R, BlockMetadata.FileBlockMetadata, FSDataInputStream>
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/block/BlockMetadata.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/block/BlockMetadata.java b/library/src/main/java/com/datatorrent/lib/io/block/BlockMetadata.java
index 534024d..a2ba183 100644
--- a/library/src/main/java/com/datatorrent/lib/io/block/BlockMetadata.java
+++ b/library/src/main/java/com/datatorrent/lib/io/block/BlockMetadata.java
@@ -20,6 +20,8 @@ package com.datatorrent.lib.io.block;
import javax.validation.constraints.NotNull;
+import org.apache.hadoop.classification.InterfaceStability;
+
import com.google.common.base.Preconditions;
/**
@@ -27,6 +29,7 @@ import com.google.common.base.Preconditions;
*
* @since 2.1.0
*/
+@InterfaceStability.Stable
public interface BlockMetadata
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/block/FSSliceReader.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/block/FSSliceReader.java b/library/src/main/java/com/datatorrent/lib/io/block/FSSliceReader.java
index ad55358..59aca47 100644
--- a/library/src/main/java/com/datatorrent/lib/io/block/FSSliceReader.java
+++ b/library/src/main/java/com/datatorrent/lib/io/block/FSSliceReader.java
@@ -18,6 +18,8 @@
*/
package com.datatorrent.lib.io.block;
+import org.apache.hadoop.classification.InterfaceStability;
+
import com.datatorrent.api.StatsListener;
import com.datatorrent.netlet.util.Slice;
@@ -29,6 +31,7 @@ import com.datatorrent.netlet.util.Slice;
*
* @since 2.1.0
*/
+@InterfaceStability.Stable
@StatsListener.DataQueueSize
public class FSSliceReader extends AbstractFSBlockReader<Slice>
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/block/ReaderContext.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/block/ReaderContext.java b/library/src/main/java/com/datatorrent/lib/io/block/ReaderContext.java
index 1ee6c53..4497b6e 100644
--- a/library/src/main/java/com/datatorrent/lib/io/block/ReaderContext.java
+++ b/library/src/main/java/com/datatorrent/lib/io/block/ReaderContext.java
@@ -25,6 +25,7 @@ import java.io.InputStream;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.PositionedReadable;
@@ -34,6 +35,7 @@ import org.apache.hadoop.fs.PositionedReadable;
* @param <STREAM> type of stream
* @since 2.1.0
*/
+@InterfaceStability.Stable
public interface ReaderContext<STREAM extends InputStream & PositionedReadable>
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileInputOperator.java
index 5067b07..8e9715e 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileInputOperator.java
@@ -35,6 +35,7 @@ import com.google.common.collect.Sets;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.commons.lang.mutable.MutableLong;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
@@ -76,6 +77,7 @@ import com.datatorrent.api.Context.OperatorContext;
* @param <T> The type of the object that this input operator reads.
* @since 1.0.2
*/
+@InterfaceStability.Stable
public abstract class AbstractFileInputOperator<T> implements InputOperator, Partitioner<AbstractFileInputOperator<T>>, StatsListener,
Operator.CheckpointListener
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
index 15a208f..a7a6560 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
@@ -39,6 +39,7 @@ import org.slf4j.LoggerFactory;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.mutable.MutableLong;
import org.apache.commons.lang3.mutable.MutableInt;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.AbstractFileSystem;
import org.apache.hadoop.fs.FSDataInputStream;
@@ -109,6 +110,7 @@ import com.datatorrent.lib.counters.BasicCounters;
*
* @since 2.0.0
*/
+@InterfaceStability.Stable
@OperatorAnnotation(checkpointableWithinAppWindow = false)
public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator implements Operator.CheckpointListener
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java
index cc549a1..dacc54f 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java
@@ -29,6 +29,8 @@ import java.util.concurrent.atomic.AtomicReference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.apache.hadoop.classification.InterfaceStability;
+
import com.google.common.collect.Maps;
import com.google.common.collect.Queues;
@@ -55,6 +57,7 @@ import com.datatorrent.common.util.NameableThreadFactory;
* @param <QUEUETUPLE> tuple enqueued each window to be processed after window is committed
* @since 2.0.0
*/
+@InterfaceStability.Stable
public abstract class AbstractReconciler<INPUT, QUEUETUPLE> extends BaseOperator implements CheckpointListener, IdleTimeHandler
{
private static final Logger logger = LoggerFactory.getLogger(AbstractReconciler.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/AbstractSingleFileOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractSingleFileOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractSingleFileOutputOperator.java
index 1844fb2..ce6cfe2 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractSingleFileOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractSingleFileOutputOperator.java
@@ -20,6 +20,8 @@ package com.datatorrent.lib.io.fs;
import javax.validation.constraints.NotNull;
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* This is a simple class that output all tuples to a single file.
*
@@ -31,6 +33,7 @@ import javax.validation.constraints.NotNull;
*
* @since 2.0.0
*/
+@InterfaceStability.Stable
public abstract class AbstractSingleFileOutputOperator<INPUT> extends AbstractFileOutputOperator<INPUT>
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java b/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java
index 17a3bb6..d08a4c8 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java
@@ -23,6 +23,7 @@ import java.util.LinkedList;
import javax.validation.constraints.NotNull;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
@@ -39,6 +40,7 @@ import com.datatorrent.api.Operator;
*
* @since 3.2.0
*/
+@InterfaceStability.Stable
public class FileSplitterBase extends AbstractFileSplitter implements Operator.IdleTimeHandler
{
@NotNull
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java b/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java
index ab70047..56cf71e 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java
@@ -41,6 +41,7 @@ import javax.validation.constraints.Size;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
@@ -75,6 +76,7 @@ import com.datatorrent.netlet.util.DTThrowable;
* @tags file
* @since 2.0.0
*/
+@InterfaceStability.Stable
@OperatorAnnotation(checkpointableWithinAppWindow = false)
public class FileSplitterInput extends AbstractFileSplitter implements InputOperator, Operator.CheckpointListener
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamCodec.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamCodec.java b/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamCodec.java
index 1029dff..0558355 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamCodec.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamCodec.java
@@ -25,11 +25,14 @@ import java.util.zip.GZIPOutputStream;
import javax.crypto.Cipher;
import javax.crypto.CipherOutputStream;
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* Filters for compression and encryption.
*
* @since 2.1.0
*/
+@InterfaceStability.Stable
public class FilterStreamCodec
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamContext.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamContext.java b/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamContext.java
index 595abde..abe8159 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamContext.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamContext.java
@@ -21,11 +21,14 @@ package com.datatorrent.lib.io.fs;
import java.io.FilterOutputStream;
import java.io.IOException;
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* An encapsulation of the filter stream that provides different methods to handle the stream.
*
* @since 2.1.0
*/
+@InterfaceStability.Stable
public interface FilterStreamContext<F extends FilterOutputStream>
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamProvider.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamProvider.java b/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamProvider.java
index 58b51af..30484bf 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamProvider.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/FilterStreamProvider.java
@@ -23,6 +23,8 @@ import java.io.IOException;
import java.io.OutputStream;
import java.util.*;
+import org.apache.hadoop.classification.InterfaceStability;
+
import com.google.common.collect.Maps;
/**
@@ -31,6 +33,7 @@ import com.google.common.collect.Maps;
*
* @since 2.1.0
*/
+@InterfaceStability.Stable
public interface FilterStreamProvider<F extends FilterOutputStream, S extends OutputStream>
{
public FilterStreamContext<F> getFilterStreamContext(S outputStream) throws IOException;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSInputOperator.java
index 43445a7..0011bbc 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSInputOperator.java
@@ -40,6 +40,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.commons.lang.mutable.MutableLong;
+import org.apache.hadoop.classification.InterfaceStability;
import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
@@ -77,6 +78,7 @@ import com.datatorrent.netlet.util.DTThrowable;
* @tags jms, input operator
* @since 0.3.2
*/
+@InterfaceStability.Stable
@OperatorAnnotation(checkpointableWithinAppWindow = false)
public abstract class AbstractJMSInputOperator<T> extends JMSBase
implements InputOperator, ActivationListener<OperatorContext>, MessageListener, ExceptionListener,
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java b/library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java
index 27079e0..df7baad 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java
@@ -27,6 +27,8 @@ import javax.jms.JMSException;
import javax.jms.Session;
import org.apache.commons.beanutils.BeanUtils;
+import org.apache.hadoop.classification.InterfaceStability;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -67,6 +69,7 @@ import com.google.common.collect.Maps;
*
* @since 0.3.2
*/
+@InterfaceStability.Stable
public class JMSBase
{
private static final Logger logger = LoggerFactory.getLogger(JMSBase.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/metric/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/metric/package-info.java b/library/src/main/java/com/datatorrent/lib/metric/package-info.java
index c2ab8aa..513237d 100644
--- a/library/src/main/java/com/datatorrent/lib/metric/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/metric/package-info.java
@@ -19,4 +19,7 @@
/**
* This package contains simple physical metrics aggregators.
*/
+@InterfaceStability.Stable
package com.datatorrent.lib.metric;
+
+import org.apache.hadoop.classification.InterfaceStability;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/stream/Counter.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/stream/Counter.java b/library/src/main/java/com/datatorrent/lib/stream/Counter.java
index 67aedb4..7c96377 100644
--- a/library/src/main/java/com/datatorrent/lib/stream/Counter.java
+++ b/library/src/main/java/com/datatorrent/lib/stream/Counter.java
@@ -18,6 +18,8 @@
*/
package com.datatorrent.lib.stream;
+import org.apache.hadoop.classification.InterfaceStability;
+
import com.datatorrent.api.Context.OperatorContext;
import com.datatorrent.api.DefaultInputPort;
import com.datatorrent.api.DefaultOutputPort;
@@ -40,6 +42,7 @@ import com.datatorrent.api.Operator.Unifier;
* @tags integer, object, count
* @since 0.3.3
*/
+@InterfaceStability.Stable
public class Counter implements Operator, Unifier<Integer>
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/stream/DevNull.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/stream/DevNull.java b/library/src/main/java/com/datatorrent/lib/stream/DevNull.java
index 8ced16b..2829f3a 100644
--- a/library/src/main/java/com/datatorrent/lib/stream/DevNull.java
+++ b/library/src/main/java/com/datatorrent/lib/stream/DevNull.java
@@ -18,6 +18,8 @@
*/
package com.datatorrent.lib.stream;
+import org.apache.hadoop.classification.InterfaceStability;
+
import com.datatorrent.common.util.BaseOperator;
import com.datatorrent.api.DefaultInputPort;
import com.datatorrent.api.annotation.Stateless;
@@ -36,6 +38,7 @@ import com.datatorrent.api.annotation.Stateless;
* @tags debug, terminate
* @since 0.3.3
*/
+@InterfaceStability.Stable
@Stateless
public class DevNull<K> extends BaseOperator
{
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/util/PojoUtils.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/util/PojoUtils.java b/library/src/main/java/com/datatorrent/lib/util/PojoUtils.java
index fd33675..d6f0e6e 100644
--- a/library/src/main/java/com/datatorrent/lib/util/PojoUtils.java
+++ b/library/src/main/java/com/datatorrent/lib/util/PojoUtils.java
@@ -35,10 +35,12 @@ import org.slf4j.LoggerFactory;
import org.apache.commons.lang3.ClassUtils;
import org.apache.commons.lang3.StringUtils;
+import org.apache.hadoop.classification.InterfaceStability;
/**
* @since 2.1.0
*/
+@InterfaceStability.Stable
public class PojoUtils
{
private static final Logger logger = LoggerFactory.getLogger(PojoUtils.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d88132ae/library/src/main/java/com/datatorrent/lib/util/comparator/SliceComparator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/util/comparator/SliceComparator.java b/library/src/main/java/com/datatorrent/lib/util/comparator/SliceComparator.java
index 4a284fe..0bc2bdd 100644
--- a/library/src/main/java/com/datatorrent/lib/util/comparator/SliceComparator.java
+++ b/library/src/main/java/com/datatorrent/lib/util/comparator/SliceComparator.java
@@ -20,6 +20,7 @@ package com.datatorrent.lib.util.comparator;
import java.util.Comparator;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.io.WritableComparator;
import com.datatorrent.netlet.util.Slice;
@@ -27,6 +28,7 @@ import com.datatorrent.netlet.util.Slice;
/**
* Default key comparator that performs lexicographical comparison of the byte arrays.
*/
+@InterfaceStability.Stable
public class SliceComparator implements Comparator<Slice>
{
@Override