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