Merge branch 'MLHR-1936.nifi-connector' of https://github.com/bbende/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/98495ab6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/98495ab6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/98495ab6 Branch: refs/heads/devel-3 Commit: 98495ab62be21cc6a5ebcff32a27dd9a02e5ea23 Parents: a44e81a 2cb8494 Author: Thomas Weise <[email protected]> Authored: Sat Jan 30 11:29:32 2016 -0800 Committer: Thomas Weise <[email protected]> Committed: Sat Jan 30 11:29:32 2016 -0800 ---------------------------------------------------------------------- contrib/pom.xml | 6 + .../contrib/nifi/AbstractNiFiInputOperator.java | 212 +++++++++++++++++ .../nifi/AbstractNiFiOutputOperator.java | 187 +++++++++++++++ .../AbstractNiFiSinglePortInputOperator.java | 83 +++++++ .../contrib/nifi/NiFiDataPacket.java | 42 ++++ .../contrib/nifi/NiFiDataPacketBuilder.java | 33 +++ .../nifi/NiFiSinglePortInputOperator.java | 72 ++++++ .../nifi/NiFiSinglePortOutputOperator.java | 126 ++++++++++ .../contrib/nifi/StandardNiFiDataPacket.java | 59 +++++ .../nifi/NiFiSinglePortInputOperatorTest.java | 200 ++++++++++++++++ .../nifi/NiFiSinglePortOutputOperatorTest.java | 231 +++++++++++++++++++ .../nifi/demo/TestNiFiInputApplication.java | 63 +++++ .../nifi/demo/TestNiFiOutputApplication.java | 85 +++++++ .../contrib/nifi/mock/MockDataPacket.java | 58 +++++ .../contrib/nifi/mock/MockSiteToSiteClient.java | 102 ++++++++ .../contrib/nifi/mock/MockTransaction.java | 166 +++++++++++++ 16 files changed, 1725 insertions(+) ----------------------------------------------------------------------
