public class WordCountRemoteBySubmitter extends Object
StormTopologyand submitted to Flink for execution in the same way as to a Storm cluster similar to
StormSubmitter. The Flink cluster can be local or remote.
This example shows how to submit the program via Java as well as Flink's command line client (ie, bin/flink).
The input is a plain text file with lines separated by newline characters.
WordCountRemoteBySubmitter <text path> <result path>
If no parameters are provided, the program is run with default data from
This example shows how to:
|Constructor and Description|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.