Package | Description |
---|---|
org.apache.storm.blobstore | |
org.apache.storm.generated | |
org.apache.storm.hdfs.blobstore |
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.
|
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) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.