This is an automated email from the ASF dual-hosted git repository.
sblackmon pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/streams.git.
from c052fa7 Merge pull request #423 from steveblackmon/STREAMS-582,583
add c9c11ac resolves STREAMS-586
add c99783d address https://github.com/smarthi feedback on
https://github.com/apache/streams/pull/424
add 4dd135d fix https://github.com/steveblackmon comment on
https://github.com/apache/streams/pull/424
new 788b5be Merge pull request #424 from steveblackmon/STREAMS-586
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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(-)
delete mode 100644
streams-contrib/streams-persist-cassandra/src/test/resources/CassandraPersistIT.conf
delete mode 100644
streams-contrib/streams-persist-cassandra/src/test/resources/cassandra.conf
delete mode 100644
streams-contrib/streams-persist-elasticsearch/src/test/resources/DatumFromMetadataProcessorIT.conf
delete mode 100644
streams-contrib/streams-persist-elasticsearch/src/test/resources/ElasticsearchParentChildUpdaterIT.conf
delete mode 100644
streams-contrib/streams-persist-elasticsearch/src/test/resources/ElasticsearchParentChildWriterIT.conf
delete mode 100644
streams-contrib/streams-persist-elasticsearch/src/test/resources/ElasticsearchPersistUpdaterIT.conf
delete mode 100644
streams-contrib/streams-persist-elasticsearch/src/test/resources/ElasticsearchPersistWriterIT.conf
copy {streams-examples/streams-examples-local/elasticsearch-reindex =>
streams-contrib/streams-persist-elasticsearch}/src/test/resources/testng.xml
(53%)
delete mode 100644
streams-contrib/streams-persist-hbase/src/test/resources/HbasePersistReaderIT.conf
delete mode 100644
streams-contrib/streams-persist-hbase/src/test/resources/HbasePersistWriterIT.conf
rename streams-contrib/streams-persist-mongo/src/main/resources/{mongo.conf =>
reference.conf} (100%)
delete mode 100644
streams-contrib/streams-persist-mongo/src/test/resources/MongoPersistIT.conf
delete mode 100644
streams-contrib/streams-persist-neo4j/src/test/resources/Neo4jBoltPersistIT.conf
delete mode 100644
streams-contrib/streams-persist-neo4j/src/test/resources/Neo4jHttpPersistIT.conf
delete mode 100644
streams-contrib/streams-persist-riak/src/test/resources/RiakBinaryPersistIT.conf
delete mode 100644
streams-contrib/streams-persist-riak/src/test/resources/RiakHttpPersistIT.conf
delete mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/ElasticsearchHdfsIT.conf
delete mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/HdfsElasticsearchIT.conf
--
To stop receiving notification emails like this one, please contact
[email protected].
