@Deprecated public class TransactionalTopologyBuilder extends Object
Trident subsumes the functionality provided by transactional topologies, so this class is deprecated.
Constructor and Description |
---|
TransactionalTopologyBuilder(String id,
String spoutId,
IOpaquePartitionedTransactionalSpout spout)
Deprecated.
|
TransactionalTopologyBuilder(String id,
String spoutId,
IOpaquePartitionedTransactionalSpout spout,
Number spoutParallelism)
Deprecated.
|
TransactionalTopologyBuilder(String id,
String spoutId,
IPartitionedTransactionalSpout spout)
Deprecated.
|
TransactionalTopologyBuilder(String id,
String spoutId,
IPartitionedTransactionalSpout spout,
Number spoutParallelism)
Deprecated.
|
TransactionalTopologyBuilder(String id,
String spoutId,
ITransactionalSpout spout)
Deprecated.
|
TransactionalTopologyBuilder(String id,
String spoutId,
ITransactionalSpout spout,
Number spoutParallelism)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
StormTopology |
buildTopology()
Deprecated.
|
TopologyBuilder |
buildTopologyBuilder()
Deprecated.
|
SpoutDeclarer |
getSpoutDeclarer()
Deprecated.
|
BoltDeclarer |
setBolt(String id,
IBasicBolt bolt)
Deprecated.
|
BoltDeclarer |
setBolt(String id,
IBasicBolt bolt,
Number parallelism)
Deprecated.
|
BoltDeclarer |
setBolt(String id,
IBatchBolt bolt)
Deprecated.
|
BoltDeclarer |
setBolt(String id,
IBatchBolt bolt,
Number parallelism)
Deprecated.
|
BoltDeclarer |
setCommitterBolt(String id,
IBatchBolt bolt)
Deprecated.
|
BoltDeclarer |
setCommitterBolt(String id,
IBatchBolt bolt,
Number parallelism)
Deprecated.
|
public TransactionalTopologyBuilder(String id, String spoutId, ITransactionalSpout spout, Number spoutParallelism)
public TransactionalTopologyBuilder(String id, String spoutId, ITransactionalSpout spout)
public TransactionalTopologyBuilder(String id, String spoutId, IPartitionedTransactionalSpout spout, Number spoutParallelism)
public TransactionalTopologyBuilder(String id, String spoutId, IPartitionedTransactionalSpout spout)
public TransactionalTopologyBuilder(String id, String spoutId, IOpaquePartitionedTransactionalSpout spout, Number spoutParallelism)
public TransactionalTopologyBuilder(String id, String spoutId, IOpaquePartitionedTransactionalSpout spout)
public SpoutDeclarer getSpoutDeclarer()
public BoltDeclarer setBolt(String id, IBatchBolt bolt)
public BoltDeclarer setBolt(String id, IBatchBolt bolt, Number parallelism)
public BoltDeclarer setCommitterBolt(String id, IBatchBolt bolt)
public BoltDeclarer setCommitterBolt(String id, IBatchBolt bolt, Number parallelism)
public BoltDeclarer setBolt(String id, IBasicBolt bolt)
public BoltDeclarer setBolt(String id, IBasicBolt bolt, Number parallelism)
public TopologyBuilder buildTopologyBuilder()
public StormTopology buildTopology()
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.