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/master Commit: ba8396f78fba72d5cf294a789661fd508d539062 Parents: 5efa71d 24fdbdf Author: Siyuan Hua <[email protected]> Authored: Tue Jan 5 23:19:51 2016 -0800 Committer: Siyuan Hua <[email protected]> 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(+) ----------------------------------------------------------------------
