public class ExclamationLocal extends Object
StormTopologyand submitted to Flink for execution in the same way as to a Storm
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.
ExclamationLocal <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–2020 The Apache Software Foundation. All rights reserved.