You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2015/02/25 03:31:44 UTC

[3/4] incubator-nifi git commit: Merge branch 'NIFI-238-kite-processors' of https://github.com/rdblue/incubator-nifi into develop

Merge branch 'NIFI-238-kite-processors' of https://github.com/rdblue/incubator-nifi into develop


Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/98cd058b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/98cd058b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/98cd058b

Branch: refs/heads/batch-stream
Commit: 98cd058b50dc46b618794760501b3ca4aa20436a
Parents: d8954ab 8242417
Author: Mark Payne <ma...@hotmail.com>
Authored: Mon Feb 23 16:19:48 2015 -0500
Committer: Mark Payne <ma...@hotmail.com>
Committed: Mon Feb 23 16:19:48 2015 -0500

----------------------------------------------------------------------
 .../nifi-kite-bundle/nifi-kite-nar/pom.xml      |  35 +++
 .../nifi-kite-processors/pom.xml                | 173 +++++++++++++
 .../processors/kite/AbstractKiteProcessor.java  | 217 ++++++++++++++++
 .../apache/nifi/processors/kite/AvroUtil.java   |  43 ++++
 .../nifi/processors/kite/ConvertCSVToAvro.java  | 258 +++++++++++++++++++
 .../nifi/processors/kite/ConvertJSONToAvro.java | 157 +++++++++++
 .../nifi/processors/kite/JSONFileReader.java    | 114 ++++++++
 .../processors/kite/StoreInKiteDataset.java     | 168 ++++++++++++
 .../data/spi/filesystem/CSVFileReaderFixed.java | 172 +++++++++++++
 .../org.apache.nifi.processor.Processor         |  17 ++
 .../processors/kite/TestCSVToAvroProcessor.java | 126 +++++++++
 .../kite/TestConfigurationProperty.java         |  77 ++++++
 .../nifi/processors/kite/TestGetSchema.java     |  94 +++++++
 .../kite/TestJSONToAvroProcessor.java           |  61 +++++
 .../kite/TestKiteProcessorsCluster.java         | 128 +++++++++
 .../kite/TestKiteStorageProcessor.java          | 167 ++++++++++++
 .../apache/nifi/processors/kite/TestUtil.java   | 103 ++++++++
 nifi/nifi-nar-bundles/nifi-kite-bundle/pom.xml  |  59 +++++
 18 files changed, 2169 insertions(+)
----------------------------------------------------------------------