Merge branch 'STREAMS-426'
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/a726b3c8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/a726b3c8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/a726b3c8 Branch: refs/heads/master Commit: a726b3c84aa5904774fdcefb9d11f2093d2688b1 Parents: 4febde2 60139e5 Author: Steve Blackmon @steveblackmon <[email protected]> Authored: Fri Oct 7 15:46:02 2016 -0500 Committer: Steve Blackmon @steveblackmon <[email protected]> Committed: Fri Oct 7 15:46:02 2016 -0500 ---------------------------------------------------------------------- .../streams-persist-elasticsearch/pom.xml | 114 +++++++++- .../ElasticsearchClientManager.java | 33 ++- .../ElasticsearchPersistWriter.java | 8 +- .../elasticsearch/ElasticsearchQuery.java | 13 -- .../MetadataFromDocumentProcessor.java | 3 + .../processor/PercolateTagProcessor.java | 43 ++-- .../src/site/markdown/index.md | 8 + .../processor/PercolateTagProcessorTest.java | 2 +- .../test/DatumFromMetadataProcessorIT.java | 107 ++++++++++ .../elasticsearch/test/ElasticsearchITs.java | 18 ++ .../test/ElasticsearchParentChildUpdaterIT.java | 159 ++++++++++++++ .../test/ElasticsearchParentChildWriterIT.java | 195 +++++++++++++++++ .../test/ElasticsearchPersistUpdaterIT.java | 208 +++++++++++++++++++ .../test/ElasticsearchPersistWriterIT.java | 142 +++++++++++++ .../test/TestDatumFromMetadataProcessor.java | 99 --------- .../test/TestDatumFromMetadataProcessorIT.java | 99 --------- .../test/TestElasticsearchPersistWriterIT.java | 197 ------------------ ...ElasticsearchPersistWriterParentChildIT.java | 183 ---------------- .../test/TestMetadataFromDocumentProcessor.java | 3 +- .../resources/ActivityChildObjectParent.json | 4 +- .../resources/DatumFromMetadataProcessorIT.conf | 7 + .../ElasticsearchParentChildUpdaterIT.conf | 8 + .../ElasticsearchParentChildWriterIT.conf | 8 + .../ElasticsearchPersistUpdaterIT.conf | 8 + .../resources/ElasticsearchPersistWriterIT.conf | 8 + streams-contrib/streams-persist-mongo/pom.xml | 107 ++++++++-- .../streams/mongo/MongoPersistReader.java | 40 ++-- .../streams/mongo/MongoPersistWriter.java | 38 ++-- .../streams/mongo/test/MongoPersistIT.java | 122 +++++++++++ .../streams/mongo/test/TestMongoPersist.java | 118 ----------- .../src/test/resources/MongoPersistIT.conf | 6 + 31 files changed, 1300 insertions(+), 808 deletions(-) ----------------------------------------------------------------------
