Merge branch 'APEXMALHAR-2076' of github.com:brightchen/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/c887d885 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/c887d885 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/c887d885 Branch: refs/heads/master Commit: c887d885f5b3272666c6be0c9d5aea30a4144541 Parents: 389a2d5 33a5c2e Author: Siyuan Hua <[email protected]> Authored: Wed Jun 29 09:05:49 2016 -0700 Committer: Siyuan Hua <[email protected]> Committed: Wed Jun 29 09:05:49 2016 -0700 ---------------------------------------------------------------------- .../kafka/AbstractKafkaOutputOperator.java | 2 +- ...pleUniqueExactlyOnceKafkaOutputOperator.java | 610 +++++++++++++++++++ .../contrib/kafka/KafkaMetadataUtil.java | 121 +++- .../datatorrent/contrib/kafka/KafkaUtil.java | 358 +++++++++++ ...upleUniqueExactlyOnceOutputOperatorTest.java | 512 ++++++++++++++++ .../contrib/kafka/KafkaUtilTester.java | 128 ++++ contrib/src/test/resources/log4j.properties | 1 + 7 files changed, 1713 insertions(+), 19 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/c887d885/contrib/src/test/resources/log4j.properties ----------------------------------------------------------------------
