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/08/27 04:46:10 UTC
[4/4] apex-malhar git commit: Merge branch 'APEXMALHAR-2063' of
https://github.com/chandnisingh/incubator-apex-malhar
Merge branch 'APEXMALHAR-2063' of https://github.com/chandnisingh/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/833cbc25
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/833cbc25
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/833cbc25
Branch: refs/heads/master
Commit: 833cbc2517f125302ccd790f314030f1c586ef3a
Parents: cae42df 1b4536c
Author: Thomas Weise <th...@datatorrent.com>
Authored: Fri Aug 26 21:43:39 2016 -0700
Committer: Thomas Weise <th...@datatorrent.com>
Committed: Fri Aug 26 21:43:39 2016 -0700
----------------------------------------------------------------------
.../kafka/AbstractKafkaInputOperator.java | 66 +-
.../kinesis/AbstractKinesisInputOperator.java | 102 ++-
.../contrib/nifi/AbstractNiFiInputOperator.java | 8 +-
.../nifi/AbstractNiFiOutputOperator.java | 4 +-
.../rabbitmq/AbstractRabbitMQInputOperator.java | 8 +-
.../AbstractRabbitMQOutputOperator.java | 4 +-
.../redis/AbstractRedisInputOperator.java | 12 +-
.../contrib/kafka/KafkaInputOperatorTest.java | 4 +-
.../kinesis/KinesisInputOperatorTest.java | 2 +-
.../nifi/NiFiSinglePortInputOperatorTest.java | 4 +-
.../rabbitmq/RabbitMQInputOperatorTest.java | 4 +-
.../contrib/redis/RedisInputOperatorTest.java | 4 +-
.../kafka/AbstractKafkaInputOperator.java | 9 +-
...afkaSinglePortExactlyOnceOutputOperator.java | 16 +-
.../malhar/kafka/KafkaOutputOperatorTest.java | 2 +-
.../db/jdbc/AbstractJdbcPollInputOperator.java | 16 +-
.../lib/io/fs/AbstractFileInputOperator.java | 19 +-
.../com/datatorrent/lib/io/fs/FileSplitter.java | 16 +-
.../lib/io/fs/FileSplitterInput.java | 33 +-
.../lib/io/jms/AbstractJMSInputOperator.java | 60 +-
.../AbstractManagedStateInnerJoinOperator.java | 4 +-
.../state/managed/AbstractManagedStateImpl.java | 37 +-
.../managed/IncrementalCheckpointManager.java | 51 +-
.../malhar/lib/wal/FSWindowDataManager.java | 723 ++++++++++++++-----
.../apex/malhar/lib/wal/FSWindowReplayWAL.java | 188 +++++
.../apex/malhar/lib/wal/FileSystemWAL.java | 292 +++++---
.../org/apache/apex/malhar/lib/wal/WAL.java | 9 +-
.../apex/malhar/lib/wal/WindowDataManager.java | 103 ++-
.../db/jdbc/JdbcPojoPollableOpeartorTest.java | 4 +-
.../io/fs/AbstractFileInputOperatorTest.java | 32 +-
.../lib/io/fs/FileSplitterInputTest.java | 201 ++++--
.../datatorrent/lib/io/fs/FileSplitterTest.java | 2 +-
.../lib/io/jms/JMSStringInputOperatorTest.java | 37 +-
.../lib/io/jms/SQSStringInputOperatorTest.java | 4 +-
.../IncrementalCheckpointManagerTest.java | 19 +-
.../malhar/lib/wal/FSWindowDataManagerTest.java | 259 ++++---
.../apex/malhar/lib/wal/FileSystemWALTest.java | 4 +-
37 files changed, 1581 insertions(+), 781 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/833cbc25/contrib/src/test/java/com/datatorrent/contrib/kafka/KafkaInputOperatorTest.java
----------------------------------------------------------------------