Path Lines of Code README.md 2 flink/flink-twitter-collection/README.md 6 flink/flink-twitter-collection/src/main/jsonschema/FlinkBatchConfiguration.json 12 flink/flink-twitter-collection/src/main/jsonschema/FlinkStreamingConfiguration.json 40 flink/flink-twitter-collection/src/main/jsonschema/StreamsFlinkConfiguration.json 48 flink/flink-twitter-collection/src/main/jsonschema/TwitterFollowingPipelineConfiguration.json 29 flink/flink-twitter-collection/src/main/jsonschema/TwitterPostsPipelineConfiguration.json 29 flink/flink-twitter-collection/src/main/jsonschema/TwitterSpritzerPipelineConfiguration.json 29 flink/flink-twitter-collection/src/main/jsonschema/TwitterUserInformationPipelineConfiguration.json 29 flink/flink-twitter-collection/src/main/resources/FlinkTwitterFollowingPipeline.dot.svg 63 flink/flink-twitter-collection/src/main/resources/FlinkTwitterPostsPipeline.dot.svg 63 flink/flink-twitter-collection/src/main/resources/FlinkTwitterSpritzerPipeline.dot.svg 47 flink/flink-twitter-collection/src/main/resources/FlinkTwitterUserInformationPipeline.dot.svg 63 flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala 141 flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala 119 flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala 116 flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala 114 flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala 126 flink/flink-twitter-collection/src/site/markdown/FlinkTwitterFollowingPipeline.md 35 flink/flink-twitter-collection/src/site/markdown/FlinkTwitterPostsPipeline.md 31 flink/flink-twitter-collection/src/site/markdown/FlinkTwitterSpritzerPipeline.md 31 flink/flink-twitter-collection/src/site/markdown/FlinkTwitterUserInformationPipeline.md 31 flink/flink-twitter-collection/src/site/markdown/index.md 17 flink/flink-twitter-collection/src/test/resources/1000twitterids.txt 1000 flink/flink-twitter-collection/src/test/resources/asf.txt 1 flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterFollowingPipelineFollowersIT.scala 38 flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterFollowingPipelineFriendsIT.scala 38 flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterPostsPipelineIT.scala 38 flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterSpritzerPipelineIT.scala 39 flink/flink-twitter-collection/src/test/scala/org/apache/streams/examples/flink/twitter/test/FlinkTwitterUserInformationPipelineIT.scala 38 flink/src/site/markdown/flink.md 7 local/elasticsearch-hdfs/README.md 6 local/elasticsearch-hdfs/src/main/jsonschema/ElasticsearchHdfsConfiguration.json 13 local/elasticsearch-hdfs/src/main/jsonschema/HdfsElasticsearchConfiguration.json 13 local/elasticsearch-hdfs/src/site/markdown/ElasticsearchHdfs.md 34 local/elasticsearch-hdfs/src/site/markdown/HdfsElasticsearch.md 36 local/elasticsearch-hdfs/src/site/markdown/index.md 17 local/elasticsearch-hdfs/src/test/resources/log4j.properties 24 local/elasticsearch-hdfs/src/test/resources/testBackup.json 26 local/elasticsearch-hdfs/src/test/resources/testRestore.json 22 local/elasticsearch-reindex/README.md 6 local/elasticsearch-reindex/src/main/jsonschema/ElasticsearchReindexConfiguration.json 13 local/elasticsearch-reindex/src/main/resources/application.json 29 local/elasticsearch-reindex/src/main/resources/log4j.properties 24 local/elasticsearch-reindex/src/site/markdown/ElasticsearchReindex.md 33 local/elasticsearch-reindex/src/site/markdown/index.md 18 local/mongo-elasticsearch-sync/README.md 6 local/mongo-elasticsearch-sync/src/main/jsonschema/MongoElasticsearchSyncConfiguration.json 13 local/mongo-elasticsearch-sync/src/site/markdown/MongoElasticsearchSync.md 35 local/mongo-elasticsearch-sync/src/site/markdown/index.md 17 local/twitter-follow-neo4j/README.md 6 local/twitter-follow-neo4j/src/main/jsonschema/TwitterFollowNeo4jConfiguration.json 13 local/twitter-follow-neo4j/src/site/markdown/TwitterFollowNeo4j.md 30 local/twitter-follow-neo4j/src/site/markdown/index.md 17 local/twitter-history-elasticsearch/README.md 6 local/twitter-history-elasticsearch/src/main/jsonschema/org/apache/streams/example/twitter/TwitterHistoryElasticsearchConfiguration.json 13 local/twitter-history-elasticsearch/src/site/markdown/TwitterHistoryElasticsearch.md 36 local/twitter-history-elasticsearch/src/site/markdown/index.md 26 local/twitter-userstream-elasticsearch/README.md 6 local/twitter-userstream-elasticsearch/src/main/jsonschema/org/apache/streams/example/twitter/TwitterUserstreamElasticsearchConfiguration.json 13 local/twitter-userstream-elasticsearch/src/site/markdown/TwitterUserstreamElasticsearch.md 28 local/twitter-userstream-elasticsearch/src/site/markdown/index.md 17 src/site/markdown/index.md 37