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 3806660 NO-JIRA Rawkintrevo adds key (#420)
add 5edc80a STREAMS-574: Merge streams-examples into streams repo
new 2818d7e Merge pull request #417 from apache/STREAMS-574
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:
pom.xml | 59 +-
{streams-schemas => streams-examples}/pom.xml | 18 +-
.../flink-twitter-collection}/README.md | 4 +-
.../flink-twitter-collection/pom.xml | 467 +++++++++
.../main/jsonschema/FlinkBatchConfiguration.json | 12 +
.../jsonschema/FlinkStreamingConfiguration.json | 40 +
.../main/jsonschema/StreamsFlinkConfiguration.json | 49 +
.../TwitterFollowingPipelineConfiguration.json | 29 +
.../TwitterPostsPipelineConfiguration.json | 29 +
.../TwitterSpritzerPipelineConfiguration.json | 29 +
...witterUserInformationPipelineConfiguration.json | 29 +
.../resources/FlinkTwitterFollowingPipeline.dot | 36 +-
.../main/resources/FlinkTwitterPostsPipeline.dot | 36 +-
.../resources/FlinkTwitterSpritzerPipeline.dot | 35 +-
.../FlinkTwitterUserInformationPipeline.dot | 36 +-
.../apache/streams/examples/flink/FlinkBase.scala | 221 +++++
.../collection/FlinkTwitterFollowingPipeline.scala | 178 ++++
.../collection/FlinkTwitterPostsPipeline.scala | 175 ++++
.../collection/FlinkTwitterSpritzerPipeline.scala | 175 ++++
.../FlinkTwitterUserInformationPipeline.scala | 184 ++++
.../site/markdown/FlinkTwitterFollowingPipeline.md | 52 +
.../src/site/markdown/FlinkTwitterPostsPipeline.md | 48 +
.../site/markdown/FlinkTwitterSpritzerPipeline.md | 48 +
.../FlinkTwitterUserInformationPipeline.md | 48 +
.../src/site/markdown/index.md | 32 +
.../flink-twitter-collection}/src/site/site.xml | 9 +-
.../src/test/resources/1000twitterids.txt | 1000 ++++++++++++++++++++
.../FlinkTwitterFollowingPipelineFollowersIT.conf | 24 +-
.../FlinkTwitterFollowingPipelineFriendsIT.conf | 23 +-
.../resources/FlinkTwitterPostsPipelineIT.conf | 23 +-
.../resources/FlinkTwitterSpritzerPipelineIT.conf | 12 +-
.../FlinkTwitterUserInformationPipelineIT.conf | 23 +-
.../src/test/resources/asf.txt | 1 +
.../FlinkTwitterFollowingPipelineFollowersIT.scala | 73 ++
.../FlinkTwitterFollowingPipelineFriendsIT.scala | 73 ++
.../twitter/test/FlinkTwitterPostsPipelineIT.scala | 73 ++
.../test/FlinkTwitterSpritzerPipelineIT.scala | 74 ++
.../FlinkTwitterUserInformationPipelineIT.scala | 73 ++
.../streams-examples-flink}/pom.xml | 20 +-
.../elasticsearch-hdfs}/README.md | 4 +-
.../elasticsearch-hdfs/pom.xml | 322 +++++++
.../apache/streams/example/ElasticsearchHdfs.java | 73 ++
.../apache/streams/example/HdfsElasticsearch.java | 73 ++
.../jsonschema/ElasticsearchHdfsConfiguration.json | 13 +
.../jsonschema/HdfsElasticsearchConfiguration.json | 13 +
.../src/main/resources/ElasticsearchHdfs.dot | 35 +
.../src/main/resources/HdfsElasticsearch.dot | 35 +
.../src/site/markdown/ElasticsearchHdfs.md | 49 +
.../src/site/markdown/HdfsElasticsearch.md | 51 +
.../elasticsearch-hdfs/src/site/markdown/index.md | 32 +
.../elasticsearch-hdfs}/src/site/site.xml | 8 +-
.../streams/example/test/ElasticsearchHdfsIT.java | 92 +-
.../streams/example/test/HdfsElasticsearchIT.java | 77 +-
.../src/test/resources/ElasticsearchHdfsIT.conf | 12 +-
.../src/test/resources/HdfsElasticsearchIT.conf | 15 +-
.../src/test/resources/log4j.properties | 26 +-
.../src/test/resources/logback.xml | 46 +
.../src/test/resources/testBackup.json | 26 +
.../src/test/resources/testRestore.json | 22 +
.../src/test/resources/testng.xml | 27 +-
.../elasticsearch-reindex}/README.md | 4 +-
.../elasticsearch-reindex/pom.xml | 278 ++++++
.../streams/example/ElasticsearchReindex.java | 78 ++
.../ElasticsearchReindexConfiguration.json | 13 +
.../src/main/resources/ElasticsearchReindex.dot | 35 +
.../src/main/resources/application.json | 29 +
.../src/main/resources/log4j.properties | 26 +-
.../src/main/resources/logback.xml | 46 +
.../src/site/markdown/ElasticsearchReindex.md | 49 +
.../src/site/markdown/index.md | 32 +
.../elasticsearch-reindex}/src/site/site.xml | 8 +-
.../example/test/ElasticsearchReindexChildIT.java | 112 +++
.../example/test/ElasticsearchReindexIT.java | 111 +++
.../example/test/ElasticsearchReindexParentIT.java | 107 +--
.../resources/ElasticsearchReindexChildIT.conf | 32 +-
.../src/test/resources/ElasticsearchReindexIT.conf | 31 +-
.../resources/ElasticsearchReindexParentIT.conf | 32 +-
.../src/test/resources/testng.xml | 36 +-
.../mongo-elasticsearch-sync}/README.md | 4 +-
.../mongo-elasticsearch-sync/pom.xml | 282 ++++++
.../streams/example/MongoElasticsearchSync.java | 77 ++
.../MongoElasticsearchSyncConfiguration.json | 13 +
.../src/main/resources/MongoElasticsearchSync.dot | 36 +
.../src/site/markdown/MongoElasticsearchSync.md | 50 +
.../src/site/markdown/index.md | 31 +
.../mongo-elasticsearch-sync}/src/site/site.xml | 9 +-
.../example/test/MongoElasticsearchSyncIT.java | 82 +-
.../test/resources/MongoElasticsearchSyncIT.conf | 22 +-
.../src/test/resources/testng.xml | 21 +-
.../streams-examples-local}/pom.xml | 27 +-
.../twitter-follow-neo4j}/README.md | 4 +-
.../twitter-follow-neo4j/pom.xml | 256 +++++
.../apache/streams/example/TwitterFollowNeo4j.java | 104 ++
.../TwitterFollowNeo4jConfiguration.json | 13 +
.../src/main/resources/TwitterFollowNeo4j.dot | 39 +
.../src/site/markdown/TwitterFollowNeo4j.md | 45 +
.../src/site/markdown/index.md | 31 +
.../twitter-follow-neo4j}/src/site/site.xml | 11 +-
.../streams/example/test/TwitterFollowNeo4jIT.java | 87 +-
.../src/test/resources/TwitterFollowNeo4jIT.conf | 13 +-
.../twitter-history-elasticsearch}/README.md | 6 +-
.../twitter-history-elasticsearch/pom.xml | 284 ++++++
.../example/TwitterHistoryElasticsearch.java | 84 ++
.../TwitterHistoryElasticsearchConfiguration.json | 13 +
.../main/resources/TwitterHistoryElasticsearch.dot | 39 +
.../site/markdown/TwitterHistoryElasticsearch.md | 53 ++
.../src/site/markdown/index.md | 42 +
.../src/site/site.xml | 11 +-
.../test/TwitterHistoryElasticsearchIT.java | 80 +-
.../resources/TwitterHistoryElasticsearchIT.conf | 17 +-
.../twitter-userstream-elasticsearch}/README.md | 6 +-
.../twitter-userstream-elasticsearch/pom.xml | 237 +++++
.../example/TwitterUserstreamElasticsearch.java | 147 +++
...witterUserstreamElasticsearchConfiguration.json | 13 +
.../resources/TwitterUserstreamElasticsearch.dot | 46 +
.../markdown/TwitterUserstreamElasticsearch.md | 43 +
.../src/site/markdown/index.md | 31 +
.../src/site/site.xml | 11 +-
.../test/TwitterUserstreamElasticsearchIT.java | 82 +-
.../TwitterUserstreamElasticsearchIT.conf | 18 +-
120 files changed, 7489 insertions(+), 711 deletions(-)
copy {streams-schemas => streams-examples}/pom.xml (77%)
copy {streams-components/streams-filters =>
streams-examples/streams-examples-flink/flink-twitter-collection}/README.md
(77%)
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/pom.xml
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/jsonschema/FlinkBatchConfiguration.json
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/jsonschema/FlinkStreamingConfiguration.json
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/jsonschema/StreamsFlinkConfiguration.json
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/jsonschema/TwitterFollowingPipelineConfiguration.json
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/jsonschema/TwitterPostsPipelineConfiguration.json
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/jsonschema/TwitterSpritzerPipelineConfiguration.json
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/jsonschema/TwitterUserInformationPipelineConfiguration.json
copy streams-contrib/streams-persist-console/src/main/resources/components.dot
=>
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/resources/FlinkTwitterFollowingPipeline.dot
(52%)
copy streams-contrib/streams-persist-console/src/main/resources/components.dot
=>
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/resources/FlinkTwitterPostsPipeline.dot
(53%)
copy
streams-contrib/streams-provider-google/google-gmail/src/main/resources/components.dot
=>
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/resources/FlinkTwitterSpritzerPipeline.dot
(59%)
copy streams-contrib/streams-persist-console/src/main/resources/components.dot
=>
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/resources/FlinkTwitterUserInformationPipeline.dot
(51%)
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/site/markdown/FlinkTwitterFollowingPipeline.md
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/site/markdown/FlinkTwitterPostsPipeline.md
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/site/markdown/FlinkTwitterSpritzerPipeline.md
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/site/markdown/FlinkTwitterUserInformationPipeline.md
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/site/markdown/index.md
copy {streams-contrib/streams-persist-cassandra =>
streams-examples/streams-examples-flink/flink-twitter-collection}/src/site/site.xml
(78%)
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/resources/1000twitterids.txt
copy
streams-contrib/streams-provider-twitter/src/test/resources/TwitterIT.conf =>
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/resources/FlinkTwitterFollowingPipelineFollowersIT.conf
(65%)
copy
streams-contrib/streams-provider-twitter/src/test/resources/TwitterIT.conf =>
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/resources/FlinkTwitterFollowingPipelineFriendsIT.conf
(66%)
copy streams-config/src/test/resources/componentTest.conf =>
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/resources/FlinkTwitterPostsPipelineIT.conf
(70%)
copy
streams-contrib/streams-provider-twitter/src/test/resources/TwitterStreamProviderIT.conf
=>
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/resources/FlinkTwitterSpritzerPipelineIT.conf
(78%)
copy streams-config/src/test/resources/componentTest.conf =>
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/resources/FlinkTwitterUserInformationPipelineIT.conf
(68%)
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/resources/asf.txt
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterFollowingPipelineFollowersIT.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterFollowingPipelineFriendsIT.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterPostsPipelineIT.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterSpritzerPipelineIT.scala
create mode 100644
streams-examples/streams-examples-flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterUserInformationPipelineIT.scala
copy {streams-schemas => streams-examples/streams-examples-flink}/pom.xml (73%)
copy {streams-runtimes/streams-runtime-local =>
streams-examples/streams-examples-local/elasticsearch-hdfs}/README.md (78%)
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/pom.xml
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/ElasticsearchHdfs.java
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/HdfsElasticsearch.java
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/main/jsonschema/ElasticsearchHdfsConfiguration.json
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/main/jsonschema/HdfsElasticsearchConfiguration.json
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/main/resources/ElasticsearchHdfs.dot
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/main/resources/HdfsElasticsearch.dot
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/site/markdown/ElasticsearchHdfs.md
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/site/markdown/HdfsElasticsearch.md
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/site/markdown/index.md
copy {streams-contrib/streams-persist-cassandra =>
streams-examples/streams-examples-local/elasticsearch-hdfs}/src/site/site.xml
(84%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/java/org/apache/streams/elasticsearch/test/ElasticsearchPersistWriterIT.java
=>
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/java/org/apache/streams/example/test/ElasticsearchHdfsIT.java
(51%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/java/org/apache/streams/elasticsearch/test/ElasticsearchPersistWriterIT.java
=>
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/java/org/apache/streams/example/test/HdfsElasticsearchIT.java
(57%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/resources/DatumFromMetadataProcessorIT.conf
=>
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/ElasticsearchHdfsIT.conf
(79%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/resources/ElasticsearchPersistUpdaterIT.conf
=>
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/HdfsElasticsearchIT.conf
(75%)
copy
streams-runtimes/streams-runtime-dropwizard/src/test/resources/configuration.yml
=>
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/log4j.properties
(68%)
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/logback.xml
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/testBackup.json
create mode 100644
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/testRestore.json
copy streams-contrib/streams-persist-cassandra/src/site/site.xml =>
streams-examples/streams-examples-local/elasticsearch-hdfs/src/test/resources/testng.xml
(61%)
copy {streams-runtimes/streams-runtime-local =>
streams-examples/streams-examples-local/elasticsearch-reindex}/README.md (78%)
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/pom.xml
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/main/java/org/apache/streams/example/ElasticsearchReindex.java
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/main/jsonschema/ElasticsearchReindexConfiguration.json
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/main/resources/ElasticsearchReindex.dot
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/main/resources/application.json
copy
streams-runtimes/streams-runtime-dropwizard/src/test/resources/configuration.yml
=>
streams-examples/streams-examples-local/elasticsearch-reindex/src/main/resources/log4j.properties
(68%)
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/main/resources/logback.xml
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/site/markdown/ElasticsearchReindex.md
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/site/markdown/index.md
copy {streams-contrib/streams-persist-cassandra =>
streams-examples/streams-examples-local/elasticsearch-reindex}/src/site/site.xml
(84%)
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/test/java/org/apache/streams/example/test/ElasticsearchReindexChildIT.java
create mode 100644
streams-examples/streams-examples-local/elasticsearch-reindex/src/test/java/org/apache/streams/example/test/ElasticsearchReindexIT.java
copy
streams-contrib/streams-persist-elasticsearch/src/test/java/org/apache/streams/elasticsearch/test/ElasticsearchPersistWriterIT.java
=>
streams-examples/streams-examples-local/elasticsearch-reindex/src/test/java/org/apache/streams/example/test/ElasticsearchReindexParentIT.java
(50%)
copy
streams-contrib/streams-persist-elasticsearch/src/main/resources/elasticsearch-read.conf
=>
streams-examples/streams-examples-local/elasticsearch-reindex/src/test/resources/ElasticsearchReindexChildIT.conf
(66%)
copy
streams-contrib/streams-persist-elasticsearch/src/main/resources/elasticsearch-read.conf
=>
streams-examples/streams-examples-local/elasticsearch-reindex/src/test/resources/ElasticsearchReindexIT.conf
(67%)
copy
streams-contrib/streams-persist-elasticsearch/src/main/resources/elasticsearch-read.conf
=>
streams-examples/streams-examples-local/elasticsearch-reindex/src/test/resources/ElasticsearchReindexParentIT.conf
(66%)
copy streams-runtimes/pom.xml =>
streams-examples/streams-examples-local/elasticsearch-reindex/src/test/resources/testng.xml
(53%)
copy {streams-components/streams-filters =>
streams-examples/streams-examples-local/mongo-elasticsearch-sync}/README.md
(77%)
create mode 100644
streams-examples/streams-examples-local/mongo-elasticsearch-sync/pom.xml
create mode 100644
streams-examples/streams-examples-local/mongo-elasticsearch-sync/src/main/java/org/apache/streams/example/MongoElasticsearchSync.java
create mode 100644
streams-examples/streams-examples-local/mongo-elasticsearch-sync/src/main/jsonschema/MongoElasticsearchSyncConfiguration.json
create mode 100644
streams-examples/streams-examples-local/mongo-elasticsearch-sync/src/main/resources/MongoElasticsearchSync.dot
create mode 100644
streams-examples/streams-examples-local/mongo-elasticsearch-sync/src/site/markdown/MongoElasticsearchSync.md
create mode 100644
streams-examples/streams-examples-local/mongo-elasticsearch-sync/src/site/markdown/index.md
copy {streams-contrib/streams-persist-cassandra =>
streams-examples/streams-examples-local/mongo-elasticsearch-sync}/src/site/site.xml
(77%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/java/org/apache/streams/elasticsearch/test/ElasticsearchPersistWriterIT.java
=>
streams-examples/streams-examples-local/mongo-elasticsearch-sync/src/test/java/org/apache/streams/example/test/MongoElasticsearchSyncIT.java
(50%)
copy
streams-contrib/streams-persist-mongo/src/test/resources/MongoPersistIT.conf =>
streams-examples/streams-examples-local/mongo-elasticsearch-sync/src/test/resources/MongoElasticsearchSyncIT.conf
(66%)
copy streams-contrib/streams-persist-cassandra/src/site/site.xml =>
streams-examples/streams-examples-local/mongo-elasticsearch-sync/src/test/resources/testng.xml
(70%)
copy {streams-runtimes => streams-examples/streams-examples-local}/pom.xml
(63%)
copy {streams-contrib/streams-provider-rss =>
streams-examples/streams-examples-local/twitter-follow-neo4j}/README.md (78%)
create mode 100644
streams-examples/streams-examples-local/twitter-follow-neo4j/pom.xml
create mode 100644
streams-examples/streams-examples-local/twitter-follow-neo4j/src/main/java/org/apache/streams/example/TwitterFollowNeo4j.java
create mode 100644
streams-examples/streams-examples-local/twitter-follow-neo4j/src/main/jsonschema/TwitterFollowNeo4jConfiguration.json
create mode 100644
streams-examples/streams-examples-local/twitter-follow-neo4j/src/main/resources/TwitterFollowNeo4j.dot
create mode 100644
streams-examples/streams-examples-local/twitter-follow-neo4j/src/site/markdown/TwitterFollowNeo4j.md
create mode 100644
streams-examples/streams-examples-local/twitter-follow-neo4j/src/site/markdown/index.md
copy {streams-contrib/streams-persist-cassandra =>
streams-examples/streams-examples-local/twitter-follow-neo4j}/src/site/site.xml
(74%)
copy
streams-contrib/streams-persist-neo4j/src/test/java/org/apache/streams/neo4j/test/Neo4jBoltPersistIT.java
=>
streams-examples/streams-examples-local/twitter-follow-neo4j/src/test/java/org/apache/streams/example/test/TwitterFollowNeo4jIT.java
(53%)
copy
streams-contrib/streams-persist-neo4j/src/test/resources/Neo4jBoltPersistIT.conf
=>
streams-examples/streams-examples-local/twitter-follow-neo4j/src/test/resources/TwitterFollowNeo4jIT.conf
(78%)
copy {streams-components/streams-filters =>
streams-examples/streams-examples-local/twitter-history-elasticsearch}/README.md
(62%)
create mode 100644
streams-examples/streams-examples-local/twitter-history-elasticsearch/pom.xml
create mode 100644
streams-examples/streams-examples-local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/TwitterHistoryElasticsearch.java
create mode 100644
streams-examples/streams-examples-local/twitter-history-elasticsearch/src/main/jsonschema/org/apache/streams/example/twitter/TwitterHistoryElasticsearchConfiguration.json
create mode 100644
streams-examples/streams-examples-local/twitter-history-elasticsearch/src/main/resources/TwitterHistoryElasticsearch.dot
create mode 100644
streams-examples/streams-examples-local/twitter-history-elasticsearch/src/site/markdown/TwitterHistoryElasticsearch.md
create mode 100644
streams-examples/streams-examples-local/twitter-history-elasticsearch/src/site/markdown/index.md
copy {streams-contrib/streams-persist-cassandra =>
streams-examples/streams-examples-local/twitter-history-elasticsearch}/src/site/site.xml
(73%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/java/org/apache/streams/elasticsearch/test/ElasticsearchPersistWriterIT.java
=>
streams-examples/streams-examples-local/twitter-history-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterHistoryElasticsearchIT.java
(54%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/resources/ElasticsearchPersistUpdaterIT.conf
=>
streams-examples/streams-examples-local/twitter-history-elasticsearch/src/test/resources/TwitterHistoryElasticsearchIT.conf
(74%)
copy {streams-components/streams-filters =>
streams-examples/streams-examples-local/twitter-userstream-elasticsearch}/README.md
(61%)
create mode 100644
streams-examples/streams-examples-local/twitter-userstream-elasticsearch/pom.xml
create mode 100644
streams-examples/streams-examples-local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/example/TwitterUserstreamElasticsearch.java
create mode 100644
streams-examples/streams-examples-local/twitter-userstream-elasticsearch/src/main/jsonschema/org/apache/streams/example/twitter/TwitterUserstreamElasticsearchConfiguration.json
create mode 100644
streams-examples/streams-examples-local/twitter-userstream-elasticsearch/src/main/resources/TwitterUserstreamElasticsearch.dot
create mode 100644
streams-examples/streams-examples-local/twitter-userstream-elasticsearch/src/site/markdown/TwitterUserstreamElasticsearch.md
create mode 100644
streams-examples/streams-examples-local/twitter-userstream-elasticsearch/src/site/markdown/index.md
copy {streams-contrib/streams-persist-cassandra =>
streams-examples/streams-examples-local/twitter-userstream-elasticsearch}/src/site/site.xml
(73%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/java/org/apache/streams/elasticsearch/test/ElasticsearchPersistWriterIT.java
=>
streams-examples/streams-examples-local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java
(54%)
copy
streams-contrib/streams-persist-elasticsearch/src/test/resources/ElasticsearchPersistUpdaterIT.conf
=>
streams-examples/streams-examples-local/twitter-userstream-elasticsearch/src/test/resources/TwitterUserstreamElasticsearchIT.conf
(73%)
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
