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/01/06 08:20:56 UTC
[2/2] incubator-apex-malhar git commit: Merge branch
'MLHR-1956-KafkaOutput-Batch' of
https://github.com/chaithu14/incubator-apex-malhar into devel-3
Merge branch 'MLHR-1956-KafkaOutput-Batch' of https://github.com/chaithu14/incubator-apex-malhar into devel-3
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/ba8396f7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/ba8396f7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/ba8396f7
Branch: refs/heads/devel-3
Commit: ba8396f78fba72d5cf294a789661fd508d539062
Parents: 5efa71d 24fdbdf
Author: Siyuan Hua <hs...@apache.org>
Authored: Tue Jan 5 23:19:51 2016 -0800
Committer: Siyuan Hua <hs...@apache.org>
Committed: Tue Jan 5 23:19:51 2016 -0800
----------------------------------------------------------------------
.../kafka/AbstractKafkaOutputOperator.java | 19 ++
.../contrib/kafka/POJOKafkaOutputOperator.java | 261 +++++++++++++++++++
.../contrib/kafka/KafkaOutputOperatorTest.java | 67 +++++
3 files changed, 347 insertions(+)
----------------------------------------------------------------------