public class ExclamationTopology extends Object
StormTopology
.
The input is a plain text file with lines separated by newline characters.
Usage: Exclamation[Local|RemoteByClient|RemoteBySubmitter] <text path>
<result path>
If no parameters are provided, the program is run with default data from WordCountData
.
This example shows how to:
Constructor and Description |
---|
ExclamationTopology() |
Modifier and Type | Method and Description |
---|---|
static org.apache.storm.topology.TopologyBuilder |
buildTopology() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.