You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2016/10/10 21:27:21 UTC
[6/6] incubator-streams git commit: Merge branch 'STREAMS-426'
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 <sb...@apache.org>
Authored: Fri Oct 7 15:46:02 2016 -0500
Committer: Steve Blackmon @steveblackmon <sb...@apache.org>
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(-)
----------------------------------------------------------------------