public class WordCountLocalByName extends Object
StormTopology
and submitted to Flink for execution in the
same way as to a Storm LocalCluster
. In contrast to WordCountLocal
all 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 StormTopology
via Flink command line clients (ie, bin/flink).
The input is a plain text file with lines separated by newline characters.
Usage: WordCountLocalByName <text path> <result path>
If no parameters are provided, the program is run with default data from WordCountData
.
This example shows how to:
Modifier and Type | Field and Description |
---|---|
static String |
topologyId |
Constructor and Description |
---|
WordCountLocalByName() |
public static final String topologyId
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.