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/01/18 17:29:20 UTC
[streams] branch master updated (3806660 -> 2818d7e)
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
['"commits@streams.apache.org" <co...@streams.apache.org>'].
[streams] 01/01: Merge pull request #417 from apache/STREAMS-574
Posted by sb...@apache.org.
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 2818d7edf220eafb7edb935f13705e561a2fe695
Merge: 3806660 5edc80a
Author: Steve Blackmon <sb...@apache.org>
AuthorDate: Thu Jan 18 11:29:18 2018 -0600
Merge pull request #417 from apache/STREAMS-574
STREAMS-574: Merge streams-examples into streams repo
pom.xml | 59 +-
streams-examples/pom.xml | 42 +
.../flink-twitter-collection/README.md | 8 +
.../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 | 37 +
.../main/resources/FlinkTwitterPostsPipeline.dot | 37 +
.../resources/FlinkTwitterSpritzerPipeline.dot | 33 +
.../FlinkTwitterUserInformationPipeline.dot | 37 +
.../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 | 28 +
.../src/test/resources/1000twitterids.txt | 1000 ++++++++++++++++++++
.../FlinkTwitterFollowingPipelineFollowersIT.conf | 36 +
.../FlinkTwitterFollowingPipelineFriendsIT.conf | 35 +
.../resources/FlinkTwitterPostsPipelineIT.conf | 31 +
.../resources/FlinkTwitterSpritzerPipelineIT.conf | 31 +
.../FlinkTwitterUserInformationPipelineIT.conf | 31 +
.../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/streams-examples-flink/pom.xml | 44 +
.../elasticsearch-hdfs/README.md | 8 +
.../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 | 25 +
.../streams/example/test/ElasticsearchHdfsIT.java | 102 ++
.../streams/example/test/HdfsElasticsearchIT.java | 109 +++
.../src/test/resources/ElasticsearchHdfsIT.conf | 31 +
.../src/test/resources/HdfsElasticsearchIT.conf | 33 +
.../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 | 36 +
.../elasticsearch-reindex/README.md | 8 +
.../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 | 25 +
.../example/test/ElasticsearchReindexChildIT.java | 112 +++
.../example/test/ElasticsearchReindexIT.java | 111 +++
.../example/test/ElasticsearchReindexParentIT.java | 125 +++
.../resources/ElasticsearchReindexChildIT.conf | 37 +
.../src/test/resources/ElasticsearchReindexIT.conf | 36 +
.../resources/ElasticsearchReindexParentIT.conf | 37 +
.../src/test/resources/testng.xml | 42 +
.../mongo-elasticsearch-sync/README.md | 8 +
.../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 | 26 +
.../example/test/MongoElasticsearchSyncIT.java | 104 ++
.../test/resources/MongoElasticsearchSyncIT.conf | 35 +
.../src/test/resources/testng.xml | 30 +
streams-examples/streams-examples-local/pom.xml | 49 +
.../twitter-follow-neo4j/README.md | 8 +
.../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 | 28 +
.../streams/example/test/TwitterFollowNeo4jIT.java | 119 +++
.../src/test/resources/TwitterFollowNeo4jIT.conf | 32 +
.../twitter-history-elasticsearch/README.md | 8 +
.../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 | 28 +
.../test/TwitterHistoryElasticsearchIT.java | 104 ++
.../resources/TwitterHistoryElasticsearchIT.conf | 31 +
.../twitter-userstream-elasticsearch/README.md | 8 +
.../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 | 28 +
.../test/TwitterUserstreamElasticsearchIT.java | 106 +++
.../TwitterUserstreamElasticsearchIT.conf | 32 +
120 files changed, 8772 insertions(+), 1 deletion(-)
--
To stop receiving notification emails like this one, please contact
"commits@streams.apache.org" <co...@streams.apache.org>.