You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by hs...@apache.org on 2016/07/07 17:01:40 UTC
[2/5] apex-malhar git commit: Merge branch 'APEXMALHAR-2076' of
github.com:brightchen/incubator-apex-malhar
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 <hs...@apache.org>
Authored: Wed Jun 29 09:05:49 2016 -0700
Committer: Siyuan Hua <hs...@apache.org>
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
----------------------------------------------------------------------