TwitterFollowingPipelineConfiguration.json
include "flink.conf" include "twitter.oauth.conf" source { fields = ["ID"] scheme = file path = "target/test-classes" readerPath = "asf.txt" } destination { fields = ["DOC"] scheme = file path = "target/test-classes" writerPath = "FlinkTwitterFollowingPipelineFriendsIT" } twitter { endpoint = friends ids_only = true }
java -cp dist/flink-twitter-collection-jar-with-dependencies.jar -Dconfig.file=file://<location_of_config_file> org.apache.streams.examples.flink.twitter.collection.FlinkTwitterFollowingPipeline
flink-run.sh dist/flink-twitter-collection-jar-with-dependencies.jar org.apache.streams.examples.flink.twitter.collection.FlinkTwitterFollowingPipeline http://<location_of_config_file>
flink-run.sh yarn dist/flink-twitter-collection-jar-with-dependencies.jar org.apache.streams.examples.flink.twitter.collection.FlinkTwitterFollowingPipeline http://<location_of_config_file>