Merge branch 'STREAMS-170'
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/d6b1f779 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/d6b1f779 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/d6b1f779 Branch: refs/heads/master Commit: d6b1f779922f9161cfb57b175cdec510dbad734c Parents: 3a1b818 6620066 Author: sblackmon <[email protected]> Authored: Tue Oct 21 14:34:49 2014 -0500 Committer: sblackmon <[email protected]> Committed: Tue Oct 21 14:34:49 2014 -0500 ---------------------------------------------------------------------- .../streams-persist-elasticsearch/pom.xml | 47 +++++++ .../ElasticsearchMetadataUtil.java | 106 ++++++++++++++++ .../ElasticsearchPersistDeleter.java | 6 +- .../ElasticsearchPersistUpdater.java | 6 +- .../ElasticsearchPersistWriter.java | 47 +------ .../DatumFromMetadataAsDocumentProcessor.java | 122 +++++++++++++++++++ .../processor/DatumFromMetadataProcessor.java | 103 ++++++++++++++++ .../processor/DocumentToMetadataProcessor.java | 100 +++++++++++++++ .../ElasticsearchConfiguration.json | 3 +- .../test/TestDatumFromMetadataProcessor.java | 81 ++++++++++++ .../test/TestDocumentToMetadataProcessor.java | 63 ++++++++++ .../test/TestElasticsearchPersistWriter.java | 70 +++++++++++ 12 files changed, 703 insertions(+), 51 deletions(-) ----------------------------------------------------------------------
