public class WordCountRemoteByClient extends Object
StormTopology
and submitted to Flink for execution in the
same way as to a Storm cluster similar to NimbusClient
. The Flink cluster can be local or remote.
This example shows how to submit the program via 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: WordCountRemoteByClient <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 |
---|
WordCountRemoteByClient() |
public static final String topologyId
public static void main(String[] args) throws backtype.storm.generated.AlreadyAliveException, backtype.storm.generated.InvalidTopologyException, backtype.storm.generated.NotAliveException
backtype.storm.generated.AlreadyAliveException
backtype.storm.generated.InvalidTopologyException
backtype.storm.generated.NotAliveException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.