apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [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
Date Fri, 08 Jan 2016 02:06:35 GMT
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.&nbsp;
  * 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>


Mime
View raw message