This is an automated email from the ASF dual-hosted git repository. sblackmon pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/streams.git
commit 788b5be71df18a5cd64ee26a3cec7c8e45e7b557 Merge: c052fa7 4dd135d Author: Steve Blackmon <[email protected]> AuthorDate: Wed Mar 28 10:59:15 2018 -0500 Merge pull request #424 from steveblackmon/STREAMS-586 resolves STREAMS-586 .gitignore | 8 ++ pom.xml | 2 +- streams-contrib/streams-persist-cassandra/pom.xml | 30 +++++- .../streams/cassandra/test/CassandraPersistIT.java | 13 ++- .../src/test/resources/CassandraPersistIT.conf | 27 ----- .../src/test/resources/cassandra.conf | 27 ----- .../streams-persist-elasticsearch/pom.xml | 44 ++++---- .../test/DatumFromMetadataProcessorIT.java | 11 +- .../test/ElasticsearchParentChildUpdaterIT.java | 11 +- .../test/ElasticsearchParentChildWriterIT.java | 10 +- .../test/ElasticsearchPersistUpdaterIT.java | 11 +- .../test/ElasticsearchPersistWriterIT.java | 10 +- .../resources/DatumFromMetadataProcessorIT.conf | 23 ----- .../ElasticsearchParentChildUpdaterIT.conf | 24 ----- .../ElasticsearchParentChildWriterIT.conf | 24 ----- .../resources/ElasticsearchPersistUpdaterIT.conf | 24 ----- .../resources/ElasticsearchPersistWriterIT.conf | 24 ----- .../src/test/resources/testng.xml | 28 ++++-- streams-contrib/streams-persist-hbase/pom.xml | 37 +++++-- .../streams/hbase/test/HbasePersistReaderIT.java | 7 +- .../streams/hbase/test/HbasePersistWriterIT.java | 7 +- .../src/test/resources/HbasePersistReaderIT.conf | 26 ----- .../src/test/resources/HbasePersistWriterIT.conf | 26 ----- streams-contrib/streams-persist-mongo/pom.xml | 27 ++++- .../main/resources/{mongo.conf => reference.conf} | 0 .../apache/streams/mongo/test/MongoPersistIT.java | 5 - .../src/test/resources/MongoPersistIT.conf | 23 ----- streams-contrib/streams-persist-neo4j/pom.xml | 45 ++++++--- .../streams/neo4j/CypherQueryGraphHelper.java | 6 +- .../streams/neo4j/test/Neo4jBoltPersistIT.java | 26 ++--- .../streams/neo4j/test/Neo4jHttpPersistIT.java | 31 +++--- .../src/test/resources/Neo4jBoltPersistIT.conf | 21 ---- .../src/test/resources/Neo4jHttpPersistIT.conf | 21 ---- streams-contrib/streams-persist-riak/pom.xml | 39 ++++--- .../streams/riak/test/RiakBinaryPersistIT.java | 27 +++-- .../streams/riak/test/RiakHttpPersistIT.java | 7 +- .../src/test/resources/RiakBinaryPersistIT.conf | 22 ---- .../src/test/resources/RiakHttpPersistIT.conf | 22 ---- .../elasticsearch-hdfs/pom.xml | 90 ++++++++++++++++- .../apache/streams/example/ElasticsearchHdfs.java | 4 +- .../streams/example/test/ElasticsearchHdfsIT.java | 8 +- .../streams/example/test/HdfsElasticsearchIT.java | 8 +- .../src/test/resources/ElasticsearchHdfsIT.conf | 31 ------ .../src/test/resources/HdfsElasticsearchIT.conf | 33 ------ .../src/test/resources/testng.xml | 8 +- .../elasticsearch-reindex/pom.xml | 89 +++++++++++++++- .../example/test/ElasticsearchReindexChildIT.java | 8 +- .../example/test/ElasticsearchReindexIT.java | 8 +- .../example/test/ElasticsearchReindexParentIT.java | 8 +- .../src/test/resources/testng.xml | 12 +++ .../mongo-elasticsearch-sync/pom.xml | 112 ++++++++++++++++++++- .../example/test/MongoElasticsearchSyncIT.java | 8 +- .../src/test/resources/testng.xml | 8 +- .../twitter-history-elasticsearch/pom.xml | 105 +++++++++++++++---- .../test/TwitterHistoryElasticsearchIT.java | 6 +- .../twitter-userstream-elasticsearch/pom.xml | 111 +++++++++++++++----- .../test/TwitterUserstreamElasticsearchIT.java | 5 - 57 files changed, 747 insertions(+), 691 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
