apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [4/4] apex-malhar git commit: Merge branch 'APEXMALHAR-2063' of https://github.com/chandnisingh/incubator-apex-malhar
Date Sat, 27 Aug 2016 04:46:10 GMT
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 <thomas@datatorrent.com>
Authored: Fri Aug 26 21:43:39 2016 -0700
Committer: Thomas Weise <thomas@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
----------------------------------------------------------------------


Mime
View raw message