Merge branch 'MLHR-1950' of https://github.com/chandnisingh/incubator-apex-malhar into devel-3
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/a4e45553 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/a4e45553 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/a4e45553 Branch: refs/heads/master Commit: a4e455535c042718bf71e507f96cfd833387dbc4 Parents: ef6e95d d88132a Author: Thomas Weise <[email protected]> Authored: Wed Jan 6 08:43:41 2016 -0800 Committer: Thomas Weise <[email protected]> Committed: Wed Jan 6 08:43:41 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(-) ----------------------------------------------------------------------
