public class WordCountLocalByName extends Object
StormTopologyand submitted to Flink for execution in the same way as to a Storm
LocalCluster. In contrast to
WordCountLocalall bolts access the field of input tuples by name instead of index.
This example shows how to run program directly within Java, thus it cannot be used to submit a
via Flink command line clients (ie, bin/flink).
The input is a plain text file with lines separated by newline characters.
WordCountLocalByName <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–2019 The Apache Software Foundation. All rights reserved.