Fork me on GitHub

FlinkTwitterSpritzerPipeline

Description:

Collects twitter posts in real-time from the sample endpoint with flink.

Configuration:

TwitterSpritzerPipelineConfiguration.json

include "flink.conf"
include "twitter.oauth.conf"
destination {
  fields = ["DOC"]
  scheme = file
  path = "target/test-classes"
  writerPath = "FlinkTwitterSpritzerPipelineIT"
}
twitter {
  endpoint = sample
  track = [
    "data"
  ]
}

Run (Local):

java -cp dist/flink-twitter-collection-jar-with-dependencies.jar -Dconfig.file=file://<location_of_config_file> org.apache.streams.examples.flink.twitter.collection.FlinkTwitterSpritzerPipeline

Run (Flink):

flink-run.sh dist/flink-twitter-collection-jar-with-dependencies.jar org.apache.streams.examples.flink.twitter.collection.FlinkTwitterSpritzerPipeline http://<location_of_config_file>

Run (YARN):

flink-run.sh yarn dist/flink-twitter-collection-jar-with-dependencies.jar org.apache.streams.examples.flink.twitter.collection.FlinkTwitterSpritzerPipeline http://<location_of_config_file>

Specification:

FlinkTwitterSpritzerPipeline.dot

Diagram:

FlinkTwitterSpritzerPipeline.dot.svg

JavaDocs

Licensed under Apache License 2.0 - http://www.apache.org/licenses/LICENSE-2.0