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 */ [email protected] 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 */ [email protected] @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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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; [email protected] 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 */ [email protected] 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 */ [email protected] @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 */ [email protected] @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 */ [email protected] 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 */ [email protected] @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 */ [email protected] 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 */ [email protected] 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 */ [email protected] @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 */ [email protected] 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 */ [email protected] [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] @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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] @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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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 */ [email protected] 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. */ - [email protected] 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> */ - [email protected] 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. */ [email protected] 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. */ - [email protected] 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. + */ [email protected] +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. + */ [email protected] +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. */ - [email protected] 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. + */ [email protected] +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 */ [email protected] 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 */ [email protected] @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 */ - [email protected] 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. */ - [email protected] 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. */ - [email protected] 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 */ [email protected] 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 */ [email protected] 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. */ [email protected] 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. + */ [email protected] 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 */ [email protected] 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 */ [email protected] 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. + */ [email protected] +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>
