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 2018/03/28 15:59:18 UTC
[streams] 01/01: Merge pull request #424 from
steveblackmon/STREAMS-586
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 <sb...@apache.org>
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
sblackmon@apache.org.