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:35 UTC
[1/2] incubator-apex-malhar git commit: APEXMALHAR-1950 #resolve
#comment includes : 1. removed @Stable annotation from classes 2. add
@Evolving to classes and packages
Repository: incubator-apex-malhar
Updated Branches:
refs/heads/devel-3 b7199b7dd -> d570b8d6f
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 cec366c..3e8d8d3 100644
--- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java
+++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataQuery.java
@@ -18,7 +18,6 @@
*/
package com.datatorrent.lib.io;
-
import java.net.URI;
import java.net.URISyntaxException;
@@ -30,18 +29,14 @@ 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;
-
import com.datatorrent.api.Context.OperatorContext;
import com.datatorrent.api.DAG;
import com.datatorrent.api.DefaultOutputPort;
-
import com.datatorrent.common.experimental.AppData;
import com.datatorrent.common.experimental.AppData.EmbeddableQueryInfoProvider;
import com.datatorrent.common.util.PubSubMessage;
+import com.datatorrent.lib.appdata.StoreUtils.BufferingOutputPortFlusher;
+import com.datatorrent.lib.appdata.query.WindowBoundedService;
/**
* This is an App Data pub sub query operator. This operator is used to receive queries from
@@ -52,7 +47,6 @@ 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/d570b8d6/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 c880cfe..4d25f49 100644
--- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java
+++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketAppDataResult.java
@@ -31,8 +31,6 @@ 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.
@@ -42,7 +40,6 @@ import org.apache.hadoop.classification.InterfaceStability;
* @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/d570b8d6/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 738fc5d..cdf2ee5 100644
--- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketInputOperator.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.common.util.PubSubMessageCodec;
import com.datatorrent.common.util.PubSubWebSocketClient;
@@ -41,7 +39,6 @@ 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/d570b8d6/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketOutputOperator.java
index 4dd6186..b704191 100644
--- a/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/PubSubWebSocketOutputOperator.java
@@ -35,6 +35,7 @@ import com.datatorrent.common.util.PubSubWebSocketClient;
* @param <T>
* @since 0.3.2
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class PubSubWebSocketOutputOperator<T> extends WebSocketOutputOperator<T>
{
private String topic = null;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/SimpleSinglePortInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/SimpleSinglePortInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/SimpleSinglePortInputOperator.java
index 432dc4f..5bf31ff 100644
--- a/library/src/main/java/com/datatorrent/lib/io/SimpleSinglePortInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/SimpleSinglePortInputOperator.java
@@ -39,6 +39,7 @@ import org.apache.commons.lang3.ClassUtils;
*
* @since 0.3.2
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class SimpleSinglePortInputOperator<T> extends BaseOperator implements InputOperator, Operator.ActivationListener<OperatorContext>
{
private transient Thread ioThread;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/SmtpOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/SmtpOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/SmtpOutputOperator.java
index 99ca34d..6477021 100644
--- a/library/src/main/java/com/datatorrent/lib/io/SmtpOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/SmtpOutputOperator.java
@@ -45,6 +45,7 @@ import com.google.common.collect.Maps;
*
* @since 0.3.2
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class SmtpOutputOperator extends BaseOperator
{
public enum RecipientType
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 e6ba6b9..a2e7165 100644
--- a/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/WebSocketInputOperator.java
@@ -18,27 +18,27 @@
*/
package com.datatorrent.lib.io;
-import com.datatorrent.api.Context.OperatorContext;
-import com.ning.http.client.AsyncHttpClient;
-import com.ning.http.client.AsyncHttpClientConfigBean;
-import com.ning.http.client.websocket.WebSocket;
-import com.ning.http.client.websocket.WebSocketTextListener;
-import com.ning.http.client.websocket.WebSocketUpgradeHandler;
-
import java.io.IOException;
import java.net.URI;
import java.util.concurrent.Executors;
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;
import org.slf4j.LoggerFactory;
+import org.apache.commons.lang3.ClassUtils;
+
+import com.ning.http.client.AsyncHttpClient;
+import com.ning.http.client.AsyncHttpClientConfigBean;
+import com.ning.http.client.websocket.WebSocket;
+import com.ning.http.client.websocket.WebSocketTextListener;
+import com.ning.http.client.websocket.WebSocketUpgradeHandler;
+
+import com.datatorrent.api.Context.OperatorContext;
+
/**
* Reads via WebSocket from given URL as input stream.
* Incoming data is interpreted as JSONObject and converted to {@link java.util.Map}.
@@ -49,7 +49,6 @@ 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/d570b8d6/library/src/main/java/com/datatorrent/lib/io/WebSocketOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/WebSocketOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/WebSocketOutputOperator.java
index 21f0133..134c913 100644
--- a/library/src/main/java/com/datatorrent/lib/io/WebSocketOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/WebSocketOutputOperator.java
@@ -48,6 +48,7 @@ import com.datatorrent.api.DefaultInputPort;
* @param <T> tuple type
* @since 0.3.2
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class WebSocketOutputOperator<T> extends BaseOperator
{
private static final Logger LOG = LoggerFactory.getLogger(WebSocketOutputOperator.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java
index 6173883..1961dcf 100644
--- a/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/WebSocketServerInputOperator.java
@@ -30,6 +30,7 @@ import org.eclipse.jetty.servlet.ServletHolder;
import org.eclipse.jetty.websocket.WebSocket;
import org.eclipse.jetty.websocket.WebSocketServlet;
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class WebSocketServerInputOperator implements InputOperator
{
public static final String DEFAULT_EXTENSION = "/in";
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/WidgetOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/WidgetOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/WidgetOutputOperator.java
index c7df6e2..df8b5af 100644
--- a/library/src/main/java/com/datatorrent/lib/io/WidgetOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/WidgetOutputOperator.java
@@ -58,6 +58,7 @@ import com.datatorrent.common.util.PubSubWebSocketClient;
*
* @since 0.9.3
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class WidgetOutputOperator extends BaseOperator
{
protected transient WebSocketOutputOperator<Pair<String, Object>> wsoo = new WebSocketOutputOperator<Pair<String,Object>>(){
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 fc624b6..afde623 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,7 +34,6 @@ 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;
@@ -81,7 +80,6 @@ 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/d570b8d6/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 b083d73..d74c9c9 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,7 +20,6 @@ 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;
@@ -36,7 +35,6 @@ 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/d570b8d6/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 a2ba183..534024d 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,8 +20,6 @@ package com.datatorrent.lib.io.block;
import javax.validation.constraints.NotNull;
-import org.apache.hadoop.classification.InterfaceStability;
-
import com.google.common.base.Preconditions;
/**
@@ -29,7 +27,6 @@ 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/d570b8d6/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 59aca47..ad55358 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,8 +18,6 @@
*/
package com.datatorrent.lib.io.block;
-import org.apache.hadoop.classification.InterfaceStability;
-
import com.datatorrent.api.StatsListener;
import com.datatorrent.netlet.util.Slice;
@@ -31,7 +29,6 @@ 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/d570b8d6/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 4497b6e..1ee6c53 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,7 +25,6 @@ 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;
@@ -35,7 +34,6 @@ 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/d570b8d6/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 8e9715e..5067b07 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,7 +35,6 @@ 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;
@@ -77,7 +76,6 @@ 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/d570b8d6/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 a7a6560..15a208f 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,7 +39,6 @@ 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;
@@ -110,7 +109,6 @@ 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/d570b8d6/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java
index 1fc040e..afd86cf 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java
@@ -44,6 +44,7 @@ import com.datatorrent.lib.io.block.BlockMetadata;
*
* @since 3.2.0
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class AbstractFileSplitter extends BaseOperator
{
protected Long blockSize;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 dacc54f..4172ed4 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,8 +29,6 @@ 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;
@@ -57,7 +55,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
+@org.apache.hadoop.classification.InterfaceStability.Evolving
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/d570b8d6/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 ce6cfe2..1844fb2 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,8 +20,6 @@ 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.
*
@@ -33,7 +31,6 @@ import org.apache.hadoop.classification.InterfaceStability;
*
* @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/d570b8d6/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputFileInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputFileInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputFileInputOperator.java
index 27f555b..a9604e3 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputFileInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputFileInputOperator.java
@@ -48,6 +48,7 @@ import org.slf4j.LoggerFactory;
*
* @since 1.0.4
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class AbstractThroughputFileInputOperator<T> extends AbstractFileInputOperator<T>
{
private static final Logger LOG = LoggerFactory.getLogger(AbstractThroughputFileInputOperator.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/fs/AbstractWindowFileOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractWindowFileOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractWindowFileOutputOperator.java
index 0c8c4d3..a7ad8f9 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractWindowFileOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractWindowFileOutputOperator.java
@@ -31,6 +31,7 @@ import org.slf4j.LoggerFactory;
*
* @since 1.0.2
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class AbstractWindowFileOutputOperator<INPUT> extends AbstractFileOutputOperator<INPUT>
{
private transient String windowIdString;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 d08a4c8..17a3bb6 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,7 +23,6 @@ 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;
@@ -40,7 +39,6 @@ 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/d570b8d6/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 56cf71e..ab70047 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,7 +41,6 @@ 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;
@@ -76,7 +75,6 @@ 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/d570b8d6/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 0558355..1029dff 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,14 +25,11 @@ 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/d570b8d6/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 abe8159..595abde 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,14 +21,11 @@ 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/d570b8d6/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 30484bf..58b51af 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,8 +23,6 @@ import java.io.IOException;
import java.io.OutputStream;
import java.util.*;
-import org.apache.hadoop.classification.InterfaceStability;
-
import com.google.common.collect.Maps;
/**
@@ -33,7 +31,6 @@ 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/d570b8d6/library/src/main/java/com/datatorrent/lib/io/fs/TailFsInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/TailFsInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/TailFsInputOperator.java
index 5e03071..4ac03a6 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/TailFsInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/TailFsInputOperator.java
@@ -51,6 +51,7 @@ import com.datatorrent.api.Operator.ActivationListener;
* @tags local fs, file
* @since 0.9.4
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class TailFsInputOperator implements InputOperator, ActivationListener<OperatorContext>
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 0011bbc..43445a7 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,7 +40,6 @@ 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;
@@ -78,7 +77,6 @@ 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/d570b8d6/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSOutputOperator.java
index ee2c497..617b397 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSOutputOperator.java
@@ -50,6 +50,7 @@ import org.slf4j.LoggerFactory;
*
* @since 0.3.2
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class AbstractJMSOutputOperator extends JMSBase implements Operator
{
private static final Logger logger = LoggerFactory.getLogger(AbstractJMSOutputOperator.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSSinglePortOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSSinglePortOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSSinglePortOutputOperator.java
index 7b2568a..c7ffed3 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSSinglePortOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/AbstractJMSSinglePortOutputOperator.java
@@ -49,6 +49,7 @@ import org.slf4j.LoggerFactory;
*
* @since 0.3.2
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class AbstractJMSSinglePortOutputOperator<T> extends AbstractJMSOutputOperator
{
@SuppressWarnings("unused")
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/jms/FSPsuedoTransactionableStore.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/FSPsuedoTransactionableStore.java b/library/src/main/java/com/datatorrent/lib/io/jms/FSPsuedoTransactionableStore.java
index a260af0..61f1eb7 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/FSPsuedoTransactionableStore.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/FSPsuedoTransactionableStore.java
@@ -36,6 +36,7 @@ import org.slf4j.LoggerFactory;
*
* @since 2.0.0
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class FSPsuedoTransactionableStore extends JMSBaseTransactionableStore
{
@SuppressWarnings("unused")
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 df7baad..6db6a4d 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
@@ -26,12 +26,11 @@ import javax.jms.Destination;
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;
+import org.apache.commons.beanutils.BeanUtils;
+
import com.google.common.collect.Maps;
/**
@@ -69,7 +68,7 @@ import com.google.common.collect.Maps;
*
* @since 0.3.2
*/
-@InterfaceStability.Stable
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class JMSBase
{
private static final Logger logger = LoggerFactory.getLogger(JMSBase.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/jms/JMSBaseTransactionableStore.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/JMSBaseTransactionableStore.java b/library/src/main/java/com/datatorrent/lib/io/jms/JMSBaseTransactionableStore.java
index b23cf12..822f841 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/JMSBaseTransactionableStore.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/JMSBaseTransactionableStore.java
@@ -25,6 +25,7 @@ import com.datatorrent.lib.db.TransactionableStore;
*
* @since 2.0.0
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class JMSBaseTransactionableStore implements TransactionableStore
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/jms/JMSMultiPortOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/JMSMultiPortOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/jms/JMSMultiPortOutputOperator.java
index 1e54c27..9caa833 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/JMSMultiPortOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/JMSMultiPortOutputOperator.java
@@ -29,6 +29,7 @@ import org.slf4j.LoggerFactory;
/**
* @since 2.1.0
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class JMSMultiPortOutputOperator extends AbstractJMSOutputOperator
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/jms/JMSObjectInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/JMSObjectInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/jms/JMSObjectInputOperator.java
index 2ea2c34..aa68802 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/JMSObjectInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/JMSObjectInputOperator.java
@@ -33,6 +33,7 @@ import org.slf4j.LoggerFactory;
*
* @since 2.1.0
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class JMSObjectInputOperator extends AbstractJMSInputOperator<Object>
{
public final transient DefaultOutputPort<String> outputString = new DefaultOutputPort<String>();
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/jms/JMSStringInputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/JMSStringInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/jms/JMSStringInputOperator.java
index a72d127..97c00d8 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/JMSStringInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/JMSStringInputOperator.java
@@ -31,6 +31,7 @@ import javax.jms.TextMessage;
* @tags jms, input operator, string
* @since 0.3.3
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class JMSStringInputOperator extends AbstractJMSInputOperator<String>
{
@Override
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/jms/JMSTransactionableStore.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/jms/JMSTransactionableStore.java b/library/src/main/java/com/datatorrent/lib/io/jms/JMSTransactionableStore.java
index d142f67..4c5c265 100644
--- a/library/src/main/java/com/datatorrent/lib/io/jms/JMSTransactionableStore.java
+++ b/library/src/main/java/com/datatorrent/lib/io/jms/JMSTransactionableStore.java
@@ -30,6 +30,7 @@ import org.slf4j.LoggerFactory;
*
* @since 2.0.0
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public class JMSTransactionableStore extends JMSBaseTransactionableStore
{
private static final Logger logger = LoggerFactory.getLogger(JMSTransactionableStore.class);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/logs/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/logs/package-info.java b/library/src/main/java/com/datatorrent/lib/logs/package-info.java
index 7ba671c..53c7ce7 100644
--- a/library/src/main/java/com/datatorrent/lib/logs/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/logs/package-info.java
@@ -19,5 +19,5 @@
/**
* Library of log line processing operators.
*/
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
package com.datatorrent.lib.logs;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/math/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/math/package-info.java b/library/src/main/java/com/datatorrent/lib/math/package-info.java
index abb3c90..f583662 100644
--- a/library/src/main/java/com/datatorrent/lib/math/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/math/package-info.java
@@ -33,5 +33,5 @@
* <br>
* <br>
*/
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
package com.datatorrent.lib.math;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 513237d..c2ab8aa 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,7 +19,4 @@
/**
* 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/d570b8d6/library/src/main/java/com/datatorrent/lib/multiwindow/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/multiwindow/package-info.java b/library/src/main/java/com/datatorrent/lib/multiwindow/package-info.java
index f582c67..78a4466 100644
--- a/library/src/main/java/com/datatorrent/lib/multiwindow/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/multiwindow/package-info.java
@@ -19,5 +19,5 @@
/**
* Library of multi-window operators including sliding window.
*/
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
package com.datatorrent.lib.multiwindow;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/parser/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/parser/package-info.java b/library/src/main/java/com/datatorrent/lib/parser/package-info.java
new file mode 100644
index 0000000..d737df5
--- /dev/null
+++ b/library/src/main/java/com/datatorrent/lib/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.lib.parser;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/partitioner/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/partitioner/package-info.java b/library/src/main/java/com/datatorrent/lib/partitioner/package-info.java
new file mode 100644
index 0000000..e4ed414
--- /dev/null
+++ b/library/src/main/java/com/datatorrent/lib/partitioner/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.partitioner;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/script/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/script/package-info.java b/library/src/main/java/com/datatorrent/lib/script/package-info.java
index 77cf127..54d4006 100644
--- a/library/src/main/java/com/datatorrent/lib/script/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/script/package-info.java
@@ -19,5 +19,5 @@
/**
* Library of operators for scripting languages, including Bash, JavaScript, and Python.
*/
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
package com.datatorrent.lib.script;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/statistics/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/statistics/package-info.java b/library/src/main/java/com/datatorrent/lib/statistics/package-info.java
new file mode 100644
index 0000000..f288df8
--- /dev/null
+++ b/library/src/main/java/com/datatorrent/lib/statistics/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.statistics;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 7c96377..67aedb4 100644
--- a/library/src/main/java/com/datatorrent/lib/stream/Counter.java
+++ b/library/src/main/java/com/datatorrent/lib/stream/Counter.java
@@ -18,8 +18,6 @@
*/
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;
@@ -42,7 +40,6 @@ 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/d570b8d6/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 2829f3a..8ced16b 100644
--- a/library/src/main/java/com/datatorrent/lib/stream/DevNull.java
+++ b/library/src/main/java/com/datatorrent/lib/stream/DevNull.java
@@ -18,8 +18,6 @@
*/
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;
@@ -38,7 +36,6 @@ 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/d570b8d6/library/src/main/java/com/datatorrent/lib/stream/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/stream/package-info.java b/library/src/main/java/com/datatorrent/lib/stream/package-info.java
index 740d697..5146eb8 100644
--- a/library/src/main/java/com/datatorrent/lib/stream/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/stream/package-info.java
@@ -19,5 +19,5 @@
/**
* Library of operators for stream operations
*/
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
package com.datatorrent.lib.stream;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/streamquery/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/streamquery/package-info.java b/library/src/main/java/com/datatorrent/lib/streamquery/package-info.java
index 96f1c7f..489915f 100644
--- a/library/src/main/java/com/datatorrent/lib/streamquery/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/streamquery/package-info.java
@@ -19,5 +19,5 @@
/**
* Library of operators for streaming query language.
*/
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
package com.datatorrent.lib.streamquery;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/testbench/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/testbench/package-info.java b/library/src/main/java/com/datatorrent/lib/testbench/package-info.java
index edfe4ff..662c508 100644
--- a/library/src/main/java/com/datatorrent/lib/testbench/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/testbench/package-info.java
@@ -19,5 +19,5 @@
/**
* Library of test bench modules.
*/
-
+@org.apache.hadoop.classification.InterfaceStability.Evolving
package com.datatorrent.lib.testbench;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 d6f0e6e..fd33675 100644
--- a/library/src/main/java/com/datatorrent/lib/util/PojoUtils.java
+++ b/library/src/main/java/com/datatorrent/lib/util/PojoUtils.java
@@ -35,12 +35,10 @@ 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/d570b8d6/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java b/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java
index fce1b01..26a2e32 100644
--- a/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java
+++ b/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java
@@ -27,7 +27,6 @@ import java.util.Set;
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;
@@ -58,7 +57,6 @@ import com.datatorrent.lib.io.fs.AbstractFileInputOperator;
*
* @since 2.0.0
*/
-@InterfaceStability.Evolving
public interface WindowDataManager extends StorageAgent, Component<Context.OperatorContext>
{
/**
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/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 0bc2bdd..4a284fe 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,7 +20,6 @@ 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;
@@ -28,7 +27,6 @@ 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
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/util/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/util/package-info.java b/library/src/main/java/com/datatorrent/lib/util/package-info.java
index 0bdd0e2..f4764ee 100644
--- a/library/src/main/java/com/datatorrent/lib/util/package-info.java
+++ b/library/src/main/java/com/datatorrent/lib/util/package-info.java
@@ -16,7 +16,8 @@
* specific language governing permissions and limitations
* under the License.
*/
-/**
- * Library of shared operators and utilities.
- */
+/**
+ * Library of shared operators and utilities.
+ */
+@org.apache.hadoop.classification.InterfaceStability.Evolving
package com.datatorrent.lib.util;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/xml/AbstractXmlDOMOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/xml/AbstractXmlDOMOperator.java b/library/src/main/java/com/datatorrent/lib/xml/AbstractXmlDOMOperator.java
index a3bdd69..2ab7875 100644
--- a/library/src/main/java/com/datatorrent/lib/xml/AbstractXmlDOMOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/xml/AbstractXmlDOMOperator.java
@@ -40,6 +40,7 @@ import com.datatorrent.netlet.util.DTThrowable;
*
* @since 1.0.2
*/
+@org.apache.hadoop.classification.InterfaceStability.Evolving
public abstract class AbstractXmlDOMOperator<T> extends BaseOperator
{
protected transient DocumentBuilderFactory docFactory;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java b/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java
index 70fe83d..2f47a76 100644
--- a/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java
+++ b/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java
@@ -22,8 +22,6 @@ import java.lang.management.ManagementFactory;
import java.util.Collection;
import com.google.common.annotations.VisibleForTesting;
-
-import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.io.file.tfile.DTBCFile.Reader.BlockReader;
import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
@@ -41,7 +39,6 @@ import com.google.common.cache.Weigher;
*
* @since 2.0.0
*/
-@InterfaceStability.Evolving
public class CacheManager
{
public static final int STRING_OVERHEAD = 64;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/org/apache/hadoop/io/file/tfile/package-info.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/hadoop/io/file/tfile/package-info.java b/library/src/main/java/org/apache/hadoop/io/file/tfile/package-info.java
new file mode 100644
index 0000000..60d6d69
--- /dev/null
+++ b/library/src/main/java/org/apache/hadoop/io/file/tfile/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 org.apache.hadoop.io.file.tfile;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index a69c2ae..b117557 100644
--- a/pom.xml
+++ b/pom.xml
@@ -124,12 +124,11 @@
<onlyBinaryIncompatible>false</onlyBinaryIncompatible>
<includeSynthetic>false</includeSynthetic>
<ignoreMissingClasses>true</ignoreMissingClasses>
- <includes>
- <include>@org.apache.hadoop.classification.InterfaceStability.Stable</include>
- </includes>
<excludes>
- <exclude>@org.apache.hadoop.classification.InterfaceStability.Evolving</exclude>
- <exclude>@org.apache.hadoop.classification.InterfaceStability.Unstable</exclude>
+ <exclude>com.datatorrent.contrib.converter.Converter</exclude>
+ <exclude>com.datatorrent.contrib.schema</exclude>
+ <exclude>org.apache.hadoop.io.file.tfile</exclude>
+ <exclude>*POJO*</exclude>
</excludes>
</parameter>
<skip>${semver.plugin.skip}</skip>
[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
Posted by th...@apache.org.
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;