Modifier and Type | Method and Description |
---|---|
static void |
StormSubmitter.pushCredentials(String name,
Map stormConf,
Map<String,String> credentials)
Push a new set of credentials to the running topology.
|
static void |
StormSubmitter.submitTopology(String name,
Map stormConf,
StormTopology topology)
Submits a topology to run on the cluster.
|
static void |
StormSubmitter.submitTopology(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts)
Submits a topology to run on the cluster.
|
static void |
StormSubmitter.submitTopology(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts,
StormSubmitter.ProgressListener progressListener)
Submits a topology to run on the cluster.
|
static void |
StormSubmitter.submitTopologyAs(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts,
StormSubmitter.ProgressListener progressListener,
String asUser)
Submits a topology to run on the cluster as a particular user.
|
static void |
StormSubmitter.submitTopologyWithProgressBar(String name,
Map stormConf,
StormTopology topology)
Submits a topology to run on the cluster with a progress bar.
|
static void |
StormSubmitter.submitTopologyWithProgressBar(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts)
Submits a topology to run on the cluster with a progress bar.
|
Modifier and Type | Method and Description |
---|---|
void |
BlobStore.createBlob(String key,
byte[] data,
SettableBlobMeta meta,
Subject who)
Wrapper called to create the blob which contains the byte data
|
void |
BlobStore.createBlob(String key,
InputStream in,
SettableBlobMeta meta,
Subject who)
Wrapper called to create the blob which contains the byte data
|
AtomicOutputStream |
ClientBlobStore.createBlob(String key,
SettableBlobMeta meta)
Client facing API to create a blob.
|
AtomicOutputStream |
LocalFsBlobStore.createBlob(String key,
SettableBlobMeta meta,
Subject who) |
abstract AtomicOutputStream |
BlobStore.createBlob(String key,
SettableBlobMeta meta,
Subject who)
Creates the blob.
|
protected AtomicOutputStream |
NimbusBlobStore.createBlobToExtend(String key,
SettableBlobMeta meta) |
protected abstract AtomicOutputStream |
ClientBlobStore.createBlobToExtend(String key,
SettableBlobMeta meta)
Client facing API to create a blob.
|
void |
NimbusBlobStore.deleteBlob(String key) |
abstract void |
ClientBlobStore.deleteBlob(String key)
Client facing API to delete a blob.
|
void |
LocalFsBlobStore.deleteBlob(String key,
Subject who) |
abstract void |
BlobStore.deleteBlob(String key,
Subject who)
Deletes the blob data and metadata.
|
InputStreamWithMeta |
NimbusBlobStore.getBlob(String key) |
abstract InputStreamWithMeta |
ClientBlobStore.getBlob(String key)
Client facing API to read a blob.
|
InputStreamWithMeta |
LocalFsBlobStore.getBlob(String key,
Subject who) |
abstract InputStreamWithMeta |
BlobStore.getBlob(String key,
Subject who)
Gets the InputStream to read the blob details
|
ReadableBlobMeta |
NimbusBlobStore.getBlobMeta(String key) |
abstract ReadableBlobMeta |
ClientBlobStore.getBlobMeta(String key)
Client facing API to read the metadata information.
|
ReadableBlobMeta |
LocalFsBlobStore.getBlobMeta(String key,
Subject who) |
abstract ReadableBlobMeta |
BlobStore.getBlobMeta(String key,
Subject who)
Gets the current version of metadata for a blob to be viewed by the user or downloaded by the supervisor.
|
int |
NimbusBlobStore.getBlobReplication(String key) |
abstract int |
ClientBlobStore.getBlobReplication(String key)
Client facing API to read the replication of a blob.
|
void |
BlobStoreAclHandler.hasAnyPermissions(List<AccessControl> acl,
int mask,
Subject who,
String key)
Validates if the user has any of the permissions mentioned in the mask.
|
void |
BlobStoreAclHandler.hasPermissions(List<AccessControl> acl,
int mask,
Subject who,
String key)
Validates if the user has at least the set of permissions mentioned in the mask.
|
byte[] |
BlobStore.readBlob(String key,
Subject who)
Wrapper around readBlobTo which returns a ByteArray output stream.
|
void |
BlobStore.readBlobTo(String key,
OutputStream out,
Subject who)
Reads the blob from the blob store and writes it into the output stream.
|
void |
ClientBlobStore.setBlobMeta(String key,
SettableBlobMeta meta)
Client facing API to set the metadata for a blob.
|
void |
LocalFsBlobStore.setBlobMeta(String key,
SettableBlobMeta meta,
Subject who) |
abstract void |
BlobStore.setBlobMeta(String key,
SettableBlobMeta meta,
Subject who)
Sets the metadata with renewed acls for the blob.
|
protected void |
NimbusBlobStore.setBlobMetaToExtend(String key,
SettableBlobMeta meta) |
protected abstract void |
ClientBlobStore.setBlobMetaToExtend(String key,
SettableBlobMeta meta)
Client facing API to set the metadata for a blob.
|
AtomicOutputStream |
NimbusBlobStore.updateBlob(String key) |
abstract AtomicOutputStream |
ClientBlobStore.updateBlob(String key)
Client facing API to update a blob.
|
AtomicOutputStream |
LocalFsBlobStore.updateBlob(String key,
Subject who) |
abstract AtomicOutputStream |
BlobStore.updateBlob(String key,
Subject who)
Updates the blob data.
|
int |
NimbusBlobStore.updateBlobReplication(String key,
int replication) |
abstract int |
ClientBlobStore.updateBlobReplication(String key,
int replication)
Client facing API to update the replication of a blob.
|
int |
LocalFsBlobStore.updateBlobReplication(String key,
int replication,
Subject who) |
abstract int |
BlobStore.updateBlobReplication(String key,
int replication,
Subject who)
Modifies the replication factor of the blob.
|
static void |
BlobStore.validateKey(String key)
Validates key checking for potentially harmful patterns
|
static void |
BlobStoreAclHandler.validateSettableACLs(String key,
List<AccessControl> acls) |
void |
BlobStoreAclHandler.validateUserCanReadMeta(List<AccessControl> acl,
Subject who,
String key)
The user should be able to see the metadata if and only if they have any of READ, WRITE, or ADMIN
|
Modifier and Type | Method and Description |
---|---|
List<String> |
DependencyUploader.uploadFiles(List<File> dependencies,
boolean cleanupIfFails) |
Modifier and Type | Method and Description |
---|---|
void |
DRPCInvocationsClient.failRequest(String id) |
DRPCRequest |
DRPCInvocationsClient.fetchRequest(String func) |
void |
DRPCInvocationsClient.result(String id,
String result) |
Modifier and Type | Method and Description |
---|---|
AuthorizationException |
AuthorizationException.deepCopy() |
AuthorizationException |
Nimbus.submitTopology_result.get_aze() |
AuthorizationException |
Nimbus.submitTopologyWithOpts_result.get_aze() |
AuthorizationException |
Nimbus.killTopology_result.get_aze() |
AuthorizationException |
Nimbus.killTopologyWithOpts_result.get_aze() |
AuthorizationException |
Nimbus.activate_result.get_aze() |
AuthorizationException |
Nimbus.deactivate_result.get_aze() |
AuthorizationException |
Nimbus.rebalance_result.get_aze() |
AuthorizationException |
Nimbus.debug_result.get_aze() |
AuthorizationException |
Nimbus.uploadNewCredentials_result.get_aze() |
AuthorizationException |
Nimbus.beginCreateBlob_result.get_aze() |
AuthorizationException |
Nimbus.beginUpdateBlob_result.get_aze() |
AuthorizationException |
Nimbus.uploadBlobChunk_result.get_aze() |
AuthorizationException |
Nimbus.finishBlobUpload_result.get_aze() |
AuthorizationException |
Nimbus.cancelBlobUpload_result.get_aze() |
AuthorizationException |
Nimbus.getBlobMeta_result.get_aze() |
AuthorizationException |
Nimbus.setBlobMeta_result.get_aze() |
AuthorizationException |
Nimbus.beginBlobDownload_result.get_aze() |
AuthorizationException |
Nimbus.downloadBlobChunk_result.get_aze() |
AuthorizationException |
Nimbus.deleteBlob_result.get_aze() |
AuthorizationException |
Nimbus.getBlobReplication_result.get_aze() |
AuthorizationException |
Nimbus.updateBlobReplication_result.get_aze() |
AuthorizationException |
Nimbus.beginFileUpload_result.get_aze() |
AuthorizationException |
Nimbus.uploadChunk_result.get_aze() |
AuthorizationException |
Nimbus.finishFileUpload_result.get_aze() |
AuthorizationException |
Nimbus.beginFileDownload_result.get_aze() |
AuthorizationException |
Nimbus.downloadChunk_result.get_aze() |
AuthorizationException |
Nimbus.getNimbusConf_result.get_aze() |
AuthorizationException |
Nimbus.getClusterInfo_result.get_aze() |
AuthorizationException |
Nimbus.getLeader_result.get_aze() |
AuthorizationException |
Nimbus.isTopologyNameAllowed_result.get_aze() |
AuthorizationException |
Nimbus.getTopologyInfo_result.get_aze() |
AuthorizationException |
Nimbus.getTopologyInfoWithOpts_result.get_aze() |
AuthorizationException |
Nimbus.getTopologyPageInfo_result.get_aze() |
AuthorizationException |
Nimbus.getSupervisorPageInfo_result.get_aze() |
AuthorizationException |
Nimbus.getComponentPageInfo_result.get_aze() |
AuthorizationException |
Nimbus.getTopologyConf_result.get_aze() |
AuthorizationException |
Nimbus.getTopology_result.get_aze() |
AuthorizationException |
Nimbus.getUserTopology_result.get_aze() |
AuthorizationException |
Nimbus.getTopologyHistory_result.get_aze() |
AuthorizationException |
DistributedRPCInvocations.result_result.get_aze() |
AuthorizationException |
DistributedRPCInvocations.fetchRequest_result.get_aze() |
AuthorizationException |
DistributedRPCInvocations.failRequest_result.get_aze() |
AuthorizationException |
DistributedRPC.execute_result.get_aze() |
Modifier and Type | Method and Description |
---|---|
int |
AuthorizationException.compareTo(AuthorizationException other) |
boolean |
AuthorizationException.equals(AuthorizationException that) |
void |
Nimbus.submitTopology_result.set_aze(AuthorizationException aze) |
void |
Nimbus.submitTopologyWithOpts_result.set_aze(AuthorizationException aze) |
void |
Nimbus.killTopology_result.set_aze(AuthorizationException aze) |
void |
Nimbus.killTopologyWithOpts_result.set_aze(AuthorizationException aze) |
void |
Nimbus.activate_result.set_aze(AuthorizationException aze) |
void |
Nimbus.deactivate_result.set_aze(AuthorizationException aze) |
void |
Nimbus.rebalance_result.set_aze(AuthorizationException aze) |
void |
Nimbus.debug_result.set_aze(AuthorizationException aze) |
void |
Nimbus.uploadNewCredentials_result.set_aze(AuthorizationException aze) |
void |
Nimbus.beginCreateBlob_result.set_aze(AuthorizationException aze) |
void |
Nimbus.beginUpdateBlob_result.set_aze(AuthorizationException aze) |
void |
Nimbus.uploadBlobChunk_result.set_aze(AuthorizationException aze) |
void |
Nimbus.finishBlobUpload_result.set_aze(AuthorizationException aze) |
void |
Nimbus.cancelBlobUpload_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getBlobMeta_result.set_aze(AuthorizationException aze) |
void |
Nimbus.setBlobMeta_result.set_aze(AuthorizationException aze) |
void |
Nimbus.beginBlobDownload_result.set_aze(AuthorizationException aze) |
void |
Nimbus.downloadBlobChunk_result.set_aze(AuthorizationException aze) |
void |
Nimbus.deleteBlob_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getBlobReplication_result.set_aze(AuthorizationException aze) |
void |
Nimbus.updateBlobReplication_result.set_aze(AuthorizationException aze) |
void |
Nimbus.beginFileUpload_result.set_aze(AuthorizationException aze) |
void |
Nimbus.uploadChunk_result.set_aze(AuthorizationException aze) |
void |
Nimbus.finishFileUpload_result.set_aze(AuthorizationException aze) |
void |
Nimbus.beginFileDownload_result.set_aze(AuthorizationException aze) |
void |
Nimbus.downloadChunk_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getNimbusConf_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getClusterInfo_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getLeader_result.set_aze(AuthorizationException aze) |
void |
Nimbus.isTopologyNameAllowed_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getTopologyInfo_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getTopologyInfoWithOpts_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getTopologyPageInfo_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getSupervisorPageInfo_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getComponentPageInfo_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getTopologyConf_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getTopology_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getUserTopology_result.set_aze(AuthorizationException aze) |
void |
Nimbus.getTopologyHistory_result.set_aze(AuthorizationException aze) |
void |
DistributedRPCInvocations.result_result.set_aze(AuthorizationException aze) |
void |
DistributedRPCInvocations.fetchRequest_result.set_aze(AuthorizationException aze) |
void |
DistributedRPCInvocations.failRequest_result.set_aze(AuthorizationException aze) |
void |
DistributedRPC.execute_result.set_aze(AuthorizationException aze) |
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.Iface.activate(String name) |
void |
Nimbus.Client.activate(String name) |
BeginDownloadResult |
Nimbus.Iface.beginBlobDownload(String key) |
BeginDownloadResult |
Nimbus.Client.beginBlobDownload(String key) |
String |
Nimbus.Iface.beginCreateBlob(String key,
SettableBlobMeta meta) |
String |
Nimbus.Client.beginCreateBlob(String key,
SettableBlobMeta meta) |
String |
Nimbus.Iface.beginFileDownload(String file) |
String |
Nimbus.Client.beginFileDownload(String file) |
String |
Nimbus.Iface.beginFileUpload() |
String |
Nimbus.Client.beginFileUpload() |
String |
Nimbus.Iface.beginUpdateBlob(String key) |
String |
Nimbus.Client.beginUpdateBlob(String key) |
void |
Nimbus.Iface.cancelBlobUpload(String session) |
void |
Nimbus.Client.cancelBlobUpload(String session) |
void |
Nimbus.Iface.deactivate(String name) |
void |
Nimbus.Client.deactivate(String name) |
void |
Nimbus.Iface.debug(String name,
String component,
boolean enable,
double samplingPercentage)
Enable/disable logging the tuples generated in topology via an internal EventLogger bolt.
|
void |
Nimbus.Client.debug(String name,
String component,
boolean enable,
double samplingPercentage) |
void |
Nimbus.Iface.deleteBlob(String key) |
void |
Nimbus.Client.deleteBlob(String key) |
ByteBuffer |
Nimbus.Iface.downloadBlobChunk(String session) |
ByteBuffer |
Nimbus.Client.downloadBlobChunk(String session) |
ByteBuffer |
Nimbus.Iface.downloadChunk(String id) |
ByteBuffer |
Nimbus.Client.downloadChunk(String id) |
String |
DistributedRPC.Iface.execute(String functionName,
String funcArgs) |
String |
DistributedRPC.Client.execute(String functionName,
String funcArgs) |
void |
DistributedRPCInvocations.Iface.failRequest(String id) |
void |
DistributedRPCInvocations.Client.failRequest(String id) |
DRPCRequest |
DistributedRPCInvocations.Iface.fetchRequest(String functionName) |
DRPCRequest |
DistributedRPCInvocations.Client.fetchRequest(String functionName) |
void |
Nimbus.Iface.finishBlobUpload(String session) |
void |
Nimbus.Client.finishBlobUpload(String session) |
void |
Nimbus.Iface.finishFileUpload(String location) |
void |
Nimbus.Client.finishFileUpload(String location) |
ReadableBlobMeta |
Nimbus.Iface.getBlobMeta(String key) |
ReadableBlobMeta |
Nimbus.Client.getBlobMeta(String key) |
int |
Nimbus.Iface.getBlobReplication(String key) |
int |
Nimbus.Client.getBlobReplication(String key) |
ClusterSummary |
Nimbus.Iface.getClusterInfo() |
ClusterSummary |
Nimbus.Client.getClusterInfo() |
ComponentPageInfo |
Nimbus.Iface.getComponentPageInfo(String topology_id,
String component_id,
String window,
boolean is_include_sys) |
ComponentPageInfo |
Nimbus.Client.getComponentPageInfo(String topology_id,
String component_id,
String window,
boolean is_include_sys) |
NimbusSummary |
Nimbus.Iface.getLeader() |
NimbusSummary |
Nimbus.Client.getLeader() |
String |
Nimbus.Iface.getNimbusConf() |
String |
Nimbus.Client.getNimbusConf() |
Void |
Nimbus.AsyncClient.submitTopology_call.getResult() |
Void |
Nimbus.AsyncClient.submitTopologyWithOpts_call.getResult() |
Void |
Nimbus.AsyncClient.killTopology_call.getResult() |
Void |
Nimbus.AsyncClient.killTopologyWithOpts_call.getResult() |
Void |
Nimbus.AsyncClient.activate_call.getResult() |
Void |
Nimbus.AsyncClient.deactivate_call.getResult() |
Void |
Nimbus.AsyncClient.rebalance_call.getResult() |
Void |
Nimbus.AsyncClient.debug_call.getResult() |
Void |
Nimbus.AsyncClient.uploadNewCredentials_call.getResult() |
String |
Nimbus.AsyncClient.beginCreateBlob_call.getResult() |
String |
Nimbus.AsyncClient.beginUpdateBlob_call.getResult() |
Void |
Nimbus.AsyncClient.uploadBlobChunk_call.getResult() |
Void |
Nimbus.AsyncClient.finishBlobUpload_call.getResult() |
Void |
Nimbus.AsyncClient.cancelBlobUpload_call.getResult() |
ReadableBlobMeta |
Nimbus.AsyncClient.getBlobMeta_call.getResult() |
Void |
Nimbus.AsyncClient.setBlobMeta_call.getResult() |
BeginDownloadResult |
Nimbus.AsyncClient.beginBlobDownload_call.getResult() |
ByteBuffer |
Nimbus.AsyncClient.downloadBlobChunk_call.getResult() |
Void |
Nimbus.AsyncClient.deleteBlob_call.getResult() |
Integer |
Nimbus.AsyncClient.getBlobReplication_call.getResult() |
Integer |
Nimbus.AsyncClient.updateBlobReplication_call.getResult() |
String |
Nimbus.AsyncClient.beginFileUpload_call.getResult() |
Void |
Nimbus.AsyncClient.uploadChunk_call.getResult() |
Void |
Nimbus.AsyncClient.finishFileUpload_call.getResult() |
String |
Nimbus.AsyncClient.beginFileDownload_call.getResult() |
ByteBuffer |
Nimbus.AsyncClient.downloadChunk_call.getResult() |
String |
Nimbus.AsyncClient.getNimbusConf_call.getResult() |
ClusterSummary |
Nimbus.AsyncClient.getClusterInfo_call.getResult() |
NimbusSummary |
Nimbus.AsyncClient.getLeader_call.getResult() |
Boolean |
Nimbus.AsyncClient.isTopologyNameAllowed_call.getResult() |
TopologyInfo |
Nimbus.AsyncClient.getTopologyInfo_call.getResult() |
TopologyInfo |
Nimbus.AsyncClient.getTopologyInfoWithOpts_call.getResult() |
TopologyPageInfo |
Nimbus.AsyncClient.getTopologyPageInfo_call.getResult() |
SupervisorPageInfo |
Nimbus.AsyncClient.getSupervisorPageInfo_call.getResult() |
ComponentPageInfo |
Nimbus.AsyncClient.getComponentPageInfo_call.getResult() |
String |
Nimbus.AsyncClient.getTopologyConf_call.getResult() |
StormTopology |
Nimbus.AsyncClient.getTopology_call.getResult() |
StormTopology |
Nimbus.AsyncClient.getUserTopology_call.getResult() |
TopologyHistoryInfo |
Nimbus.AsyncClient.getTopologyHistory_call.getResult() |
Void |
DistributedRPCInvocations.AsyncClient.result_call.getResult() |
DRPCRequest |
DistributedRPCInvocations.AsyncClient.fetchRequest_call.getResult() |
Void |
DistributedRPCInvocations.AsyncClient.failRequest_call.getResult() |
String |
DistributedRPC.AsyncClient.execute_call.getResult() |
SupervisorPageInfo |
Nimbus.Iface.getSupervisorPageInfo(String id,
String host,
boolean is_include_sys) |
SupervisorPageInfo |
Nimbus.Client.getSupervisorPageInfo(String id,
String host,
boolean is_include_sys) |
StormTopology |
Nimbus.Iface.getTopology(String id)
Returns the compiled topology that contains ackers and metrics consumsers.
|
StormTopology |
Nimbus.Client.getTopology(String id) |
String |
Nimbus.Iface.getTopologyConf(String id) |
String |
Nimbus.Client.getTopologyConf(String id) |
TopologyHistoryInfo |
Nimbus.Iface.getTopologyHistory(String user) |
TopologyHistoryInfo |
Nimbus.Client.getTopologyHistory(String user) |
TopologyInfo |
Nimbus.Iface.getTopologyInfo(String id) |
TopologyInfo |
Nimbus.Client.getTopologyInfo(String id) |
TopologyInfo |
Nimbus.Iface.getTopologyInfoWithOpts(String id,
GetInfoOptions options) |
TopologyInfo |
Nimbus.Client.getTopologyInfoWithOpts(String id,
GetInfoOptions options) |
TopologyPageInfo |
Nimbus.Iface.getTopologyPageInfo(String id,
String window,
boolean is_include_sys) |
TopologyPageInfo |
Nimbus.Client.getTopologyPageInfo(String id,
String window,
boolean is_include_sys) |
StormTopology |
Nimbus.Iface.getUserTopology(String id)
Returns the user specified topology as submitted originally.
|
StormTopology |
Nimbus.Client.getUserTopology(String id) |
boolean |
Nimbus.Iface.isTopologyNameAllowed(String name) |
boolean |
Nimbus.Client.isTopologyNameAllowed(String name) |
void |
Nimbus.Iface.killTopology(String name) |
void |
Nimbus.Client.killTopology(String name) |
void |
Nimbus.Iface.killTopologyWithOpts(String name,
KillOptions options) |
void |
Nimbus.Client.killTopologyWithOpts(String name,
KillOptions options) |
void |
Nimbus.Iface.rebalance(String name,
RebalanceOptions options) |
void |
Nimbus.Client.rebalance(String name,
RebalanceOptions options) |
void |
Nimbus.Client.recv_activate() |
BeginDownloadResult |
Nimbus.Client.recv_beginBlobDownload() |
String |
Nimbus.Client.recv_beginCreateBlob() |
String |
Nimbus.Client.recv_beginFileDownload() |
String |
Nimbus.Client.recv_beginFileUpload() |
String |
Nimbus.Client.recv_beginUpdateBlob() |
void |
Nimbus.Client.recv_cancelBlobUpload() |
void |
Nimbus.Client.recv_deactivate() |
void |
Nimbus.Client.recv_debug() |
void |
Nimbus.Client.recv_deleteBlob() |
ByteBuffer |
Nimbus.Client.recv_downloadBlobChunk() |
ByteBuffer |
Nimbus.Client.recv_downloadChunk() |
String |
DistributedRPC.Client.recv_execute() |
void |
DistributedRPCInvocations.Client.recv_failRequest() |
DRPCRequest |
DistributedRPCInvocations.Client.recv_fetchRequest() |
void |
Nimbus.Client.recv_finishBlobUpload() |
void |
Nimbus.Client.recv_finishFileUpload() |
ReadableBlobMeta |
Nimbus.Client.recv_getBlobMeta() |
int |
Nimbus.Client.recv_getBlobReplication() |
ClusterSummary |
Nimbus.Client.recv_getClusterInfo() |
ComponentPageInfo |
Nimbus.Client.recv_getComponentPageInfo() |
NimbusSummary |
Nimbus.Client.recv_getLeader() |
String |
Nimbus.Client.recv_getNimbusConf() |
SupervisorPageInfo |
Nimbus.Client.recv_getSupervisorPageInfo() |
StormTopology |
Nimbus.Client.recv_getTopology() |
String |
Nimbus.Client.recv_getTopologyConf() |
TopologyHistoryInfo |
Nimbus.Client.recv_getTopologyHistory() |
TopologyInfo |
Nimbus.Client.recv_getTopologyInfo() |
TopologyInfo |
Nimbus.Client.recv_getTopologyInfoWithOpts() |
TopologyPageInfo |
Nimbus.Client.recv_getTopologyPageInfo() |
StormTopology |
Nimbus.Client.recv_getUserTopology() |
boolean |
Nimbus.Client.recv_isTopologyNameAllowed() |
void |
Nimbus.Client.recv_killTopology() |
void |
Nimbus.Client.recv_killTopologyWithOpts() |
void |
Nimbus.Client.recv_rebalance() |
void |
DistributedRPCInvocations.Client.recv_result() |
void |
Nimbus.Client.recv_setBlobMeta() |
void |
Nimbus.Client.recv_submitTopology() |
void |
Nimbus.Client.recv_submitTopologyWithOpts() |
int |
Nimbus.Client.recv_updateBlobReplication() |
void |
Nimbus.Client.recv_uploadBlobChunk() |
void |
Nimbus.Client.recv_uploadChunk() |
void |
Nimbus.Client.recv_uploadNewCredentials() |
void |
DistributedRPCInvocations.Iface.result(String id,
String result) |
void |
DistributedRPCInvocations.Client.result(String id,
String result) |
void |
Nimbus.Iface.setBlobMeta(String key,
SettableBlobMeta meta) |
void |
Nimbus.Client.setBlobMeta(String key,
SettableBlobMeta meta) |
void |
Nimbus.Iface.submitTopology(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology) |
void |
Nimbus.Client.submitTopology(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology) |
void |
Nimbus.Iface.submitTopologyWithOpts(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
SubmitOptions options) |
void |
Nimbus.Client.submitTopologyWithOpts(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
SubmitOptions options) |
int |
Nimbus.Iface.updateBlobReplication(String key,
int replication) |
int |
Nimbus.Client.updateBlobReplication(String key,
int replication) |
void |
Nimbus.Iface.uploadBlobChunk(String session,
ByteBuffer chunk) |
void |
Nimbus.Client.uploadBlobChunk(String session,
ByteBuffer chunk) |
void |
Nimbus.Iface.uploadChunk(String location,
ByteBuffer chunk) |
void |
Nimbus.Client.uploadChunk(String location,
ByteBuffer chunk) |
void |
Nimbus.Iface.uploadNewCredentials(String name,
Credentials creds) |
void |
Nimbus.Client.uploadNewCredentials(String name,
Credentials creds) |
Modifier and Type | Method and Description |
---|---|
protected void |
TridentKafkaClientWordCountNamedTopics.run(String[] args) |
Modifier and Type | Method and Description |
---|---|
LocalizedResource |
Localizer.getBlob(LocalResource localResource,
String user,
String topo,
File userFileDir)
This function either returns the blob in the existing cache or if it doesn’t exist in the cache, it will download the blob and will block until the download is complete.
|
List<LocalizedResource> |
Localizer.getBlobs(List<LocalResource> localResources,
String user,
String topo,
File userFileDir)
This function either returns the blobs in the existing cache or if they don’t exist in the cache, it downloads them in parallel (up to SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT) and will block until all of them have been downloaded
|
protected boolean |
Localizer.isLocalizedResourceUpToDate(LocalizedResource lrsrc,
ClientBlobStore blobstore) |
void |
Localizer.removeBlobReference(String key,
String user,
String topo,
boolean uncompress) |
List<LocalizedResource> |
Localizer.updateBlobs(List<LocalResource> localResources,
String user)
This function updates blobs on the supervisor.
|
Modifier and Type | Method and Description |
---|---|
static void |
StormRunner.runTopologyRemotely(StormTopology topology,
String topologyName,
Config conf) |
Modifier and Type | Method and Description |
---|---|
static void |
Utils.downloadResourcesAsSupervisor(String key,
String localFile,
ClientBlobStore cb)
Meant to be called only by the supervisor for stormjar/stormconf/stormcode files.
|
void |
Utils.downloadResourcesAsSupervisorImpl(String key,
String localFile,
ClientBlobStore cb) |
String |
DRPCClient.execute(String func,
String args) |
static long |
Utils.nimbusVersionOfBlob(String key,
ClientBlobStore cb) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.