Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.cluster | |
org.apache.storm.daemon.nimbus | |
org.apache.storm.daemon.worker | |
org.apache.storm.executor | |
org.apache.storm.generated |
Modifier and Type | Method and Description |
---|---|
void |
LocalCluster.uploadNewCredentials(String topologyName,
Credentials creds) |
void |
ILocalCluster.uploadNewCredentials(String topologyName,
Credentials creds)
Upload new credentials to a topology.
|
Modifier and Type | Method and Description |
---|---|
Credentials |
StormClusterStateImpl.credentials(String stormId,
Runnable callback) |
Credentials |
IStormClusterState.credentials(String stormId,
Runnable callback) |
Modifier and Type | Method and Description |
---|---|
void |
StormClusterStateImpl.setCredentials(String stormId,
Credentials creds,
Map<String,Object> topoConf) |
void |
IStormClusterState.setCredentials(String stormId,
Credentials creds,
Map<String,Object> topoConf) |
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.uploadNewCredentials(String topoName,
Credentials credentials) |
Modifier and Type | Method and Description |
---|---|
Credentials |
WorkerState.getCredentials() |
Modifier and Type | Method and Description |
---|---|
void |
WorkerState.setCredentials(Credentials credentials) |
Constructor and Description |
---|
WorkerState(Map<String,Object> conf,
IContext mqContext,
String topologyId,
String assignmentId,
Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier,
int port,
String workerId,
Map<String,Object> topologyConf,
IStateStorage stateStorage,
IStormClusterState stormClusterState,
Collection<IAutoCredentials> autoCredentials,
StormMetricRegistry metricRegistry,
Credentials initialCredentials) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutorShutdown.credentialsChanged(Credentials credentials) |
void |
IRunningExecutor.credentialsChanged(Credentials credentials) |
Modifier and Type | Method and Description |
---|---|
Credentials |
Credentials.deepCopy() |
Credentials |
Nimbus.uploadNewCredentials_args.get_creds() |
Credentials |
SubmitOptions.get_creds() |
Modifier and Type | Method and Description |
---|---|
int |
Credentials.compareTo(Credentials other) |
boolean |
Credentials.equals(Credentials that) |
void |
Nimbus.Client.send_uploadNewCredentials(String name,
Credentials creds) |
void |
Nimbus.uploadNewCredentials_args.set_creds(Credentials creds) |
void |
SubmitOptions.set_creds(Credentials creds) |
void |
Nimbus.Iface.uploadNewCredentials(String name,
Credentials creds) |
void |
Nimbus.Client.uploadNewCredentials(String name,
Credentials creds) |
void |
Nimbus.AsyncIface.uploadNewCredentials(String name,
Credentials creds,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
Nimbus.AsyncClient.uploadNewCredentials(String name,
Credentials creds,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
Constructor and Description |
---|
Credentials(Credentials other)
Performs a deep copy on other.
|
uploadNewCredentials_args(String name,
Credentials creds) |
uploadNewCredentials_call(String name,
Credentials creds,
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) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.