Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.blobstore | |
org.apache.storm.daemon.nimbus | |
org.apache.storm.generated | |
org.apache.storm.hdfs.blobstore | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
String |
LocalCluster.beginCreateBlob(String key,
SettableBlobMeta meta) |
Modifier and Type | Method and Description |
---|---|
protected static void |
MigrateBlobs.copyBlobStoreKeys(BlobStore bsFrom,
Subject whoFrom,
BlobStore bsTo,
Subject whoTo) |
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 abstract AtomicOutputStream |
ClientBlobStore.createBlobToExtend(String key,
SettableBlobMeta meta)
Client facing API to create a blob.
|
protected AtomicOutputStream |
LocalModeClientBlobStore.createBlobToExtend(String key,
SettableBlobMeta meta) |
protected AtomicOutputStream |
NimbusBlobStore.createBlobToExtend(String key,
SettableBlobMeta meta) |
Modifier and Type | Method and Description |
---|---|
void |
TopoCache.addTopoConf(String topoId,
Subject who,
Map<String,Object> topoConf)
Add a new topology config.
|
void |
TopoCache.addTopology(String topoId,
Subject who,
StormTopology topo)
Add a new topology.
|
String |
Nimbus.beginCreateBlob(String key,
SettableBlobMeta meta) |
Modifier and Type | Method and Description |
---|---|
KeyAlreadyExistsException |
KeyAlreadyExistsException.deepCopy() |
KeyAlreadyExistsException |
Nimbus.beginCreateBlob_result.get_kae() |
Modifier and Type | Method and Description |
---|---|
int |
KeyAlreadyExistsException.compareTo(KeyAlreadyExistsException other) |
boolean |
KeyAlreadyExistsException.equals(KeyAlreadyExistsException that) |
void |
Nimbus.beginCreateBlob_result.set_kae(KeyAlreadyExistsException kae) |
Modifier and Type | Method and Description |
---|---|
String |
Nimbus.Iface.beginCreateBlob(String key,
SettableBlobMeta meta) |
String |
Nimbus.Client.beginCreateBlob(String key,
SettableBlobMeta meta) |
String |
Nimbus.AsyncClient.beginCreateBlob_call.getResult() |
String |
Nimbus.Client.recv_beginCreateBlob() |
Constructor and Description |
---|
beginCreateBlob_result(String success,
AuthorizationException aze,
KeyAlreadyExistsException kae) |
KeyAlreadyExistsException(KeyAlreadyExistsException other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
AtomicOutputStream |
HdfsBlobStore.createBlob(String key,
SettableBlobMeta meta,
Subject who) |
AtomicOutputStream |
HdfsClientBlobStore.createBlobToExtend(String key,
SettableBlobMeta meta) |
Modifier and Type | Class and Description |
---|---|
class |
WrappedKeyAlreadyExistsException
Wraps the generated TException to allow getMessage() to return a valid string.
|
Copyright © 2019 The Apache Software Foundation. All rights reserved.