You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/29 20:12:48 UTC

[31/50] [abbrv] incubator-apex-malhar git commit: Merge branch 'MLHR-1950' of https://github.com/chandnisingh/incubator-apex-malhar into devel-3

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 <th...@datatorrent.com>
Authored: Wed Jan 6 08:43:41 2016 -0800
Committer: Thomas Weise <th...@datatorrent.com>
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(-)
----------------------------------------------------------------------