Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.daemon.nimbus | |
org.apache.storm.generated |
Modifier and Type | Method and Description |
---|---|
void |
LocalCluster.rebalance(String name,
RebalanceOptions options) |
void |
ILocalCluster.rebalance(String name,
RebalanceOptions options)
Rebalance a topology.
|
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.rebalance(String topoName,
RebalanceOptions options) |
Modifier and Type | Method and Description |
---|---|
RebalanceOptions |
RebalanceOptions.deepCopy() |
RebalanceOptions |
Nimbus.rebalance_args.get_options() |
RebalanceOptions |
TopologyActionOptions.get_rebalance_options() |
Modifier and Type | Method and Description |
---|---|
int |
RebalanceOptions.compareTo(RebalanceOptions other) |
boolean |
RebalanceOptions.equals(RebalanceOptions that) |
static TopologyActionOptions |
TopologyActionOptions.rebalance_options(RebalanceOptions value) |
void |
Nimbus.Iface.rebalance(String name,
RebalanceOptions options) |
void |
Nimbus.Client.rebalance(String name,
RebalanceOptions options) |
void |
Nimbus.AsyncIface.rebalance(String name,
RebalanceOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
Nimbus.AsyncClient.rebalance(String name,
RebalanceOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
Nimbus.Client.send_rebalance(String name,
RebalanceOptions options) |
void |
Nimbus.rebalance_args.set_options(RebalanceOptions options) |
void |
TopologyActionOptions.set_rebalance_options(RebalanceOptions value) |
Constructor and Description |
---|
rebalance_args(String name,
RebalanceOptions options) |
rebalance_call(String name,
RebalanceOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
RebalanceOptions(RebalanceOptions other)
Performs a deep copy on other.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.