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 <[email protected]> Authored: Fri Aug 26 21:43:39 2016 -0700 Committer: Thomas Weise <[email protected]> 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 ----------------------------------------------------------------------
