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:
Modifier and Type | Field and Description |
---|---|
static String |
firstBoltId |
static String |
secondBoltId |
static String |
sinkId |
static String |
spoutId |
Constructor and Description |
---|
ExclamationTopology() |
Modifier and Type | Method and Description |
---|---|
static org.apache.storm.topology.TopologyBuilder |
buildTopology() |
public static final String spoutId
public static final String firstBoltId
public static final String secondBoltId
public static final String sinkId
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.