Package | Description |
---|---|
org.apache.storm.topology | |
org.apache.storm.trident.topology |
Modifier and Type | Class and Description |
---|---|
protected class |
TopologyBuilder.SpoutGetter |
Modifier and Type | Method and Description |
---|---|
SpoutDeclarer |
TopologyBuilder.setSpout(String id,
IRichSpout spout)
Define a new spout in this topology.
|
SpoutDeclarer |
TopologyBuilder.setSpout(String id,
IRichSpout spout,
Number parallelismHint)
Define a new spout in this topology with the specified parallelism.
|
SpoutDeclarer |
TopologyBuilder.setSpout(String id,
SerializableSupplier<?> supplier)
Define a new spout in this topology.
|
SpoutDeclarer |
TopologyBuilder.setSpout(String id,
SerializableSupplier<?> supplier,
Number parallelismHint)
Define a new spout in this topology with the specified parallelism.
|
Modifier and Type | Method and Description |
---|---|
SpoutDeclarer |
TridentTopologyBuilder.setBatchPerTupleSpout(String id,
String streamName,
IRichSpout spout,
Integer parallelism,
String batchGroup) |
SpoutDeclarer |
TridentTopologyBuilder.setSpout(String id,
String streamName,
String txStateId,
IBatchSpout spout,
Integer parallelism,
String batchGroup) |
SpoutDeclarer |
TridentTopologyBuilder.setSpout(String id,
String streamName,
String txStateId,
ITridentSpout spout,
Integer parallelism,
String batchGroup) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.