You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/30 20:31:19 UTC

[2/2] incubator-apex-malhar git commit: Merge branch 'MLHR-1936.nifi-connector' of https://github.com/bbende/incubator-apex-malhar into devel-3

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 <th...@datatorrent.com>
Authored: Sat Jan 30 11:29:32 2016 -0800
Committer: Thomas Weise <th...@datatorrent.com>
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(+)
----------------------------------------------------------------------