Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.blobstore | |
org.apache.storm.daemon.nimbus | |
org.apache.storm.generated | |
org.apache.storm.hdfs.blobstore |
Modifier and Type | Method and Description |
---|---|
String |
LocalCluster.beginCreateBlob(String key,
SettableBlobMeta meta) |
void |
LocalCluster.setBlobMeta(String key,
SettableBlobMeta meta) |
Modifier and Type | Method and Description |
---|---|
SettableBlobMeta |
LocalFsBlobStoreFile.getMetadata() |
abstract SettableBlobMeta |
BlobStoreFile.getMetadata() |
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 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) |
void |
BlobStoreAclHandler.normalizeSettableBlobMeta(String key,
SettableBlobMeta meta,
Subject who,
int opMask) |
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 abstract void |
ClientBlobStore.setBlobMetaToExtend(String key,
SettableBlobMeta meta)
Client facing API to set the metadata for a blob.
|
protected void |
LocalModeClientBlobStore.setBlobMetaToExtend(String key,
SettableBlobMeta meta) |
protected void |
NimbusBlobStore.setBlobMetaToExtend(String key,
SettableBlobMeta meta) |
void |
LocalFsBlobStoreFile.setMetadata(SettableBlobMeta meta) |
abstract void |
BlobStoreFile.setMetadata(SettableBlobMeta meta) |
Modifier and Type | Method and Description |
---|---|
String |
Nimbus.beginCreateBlob(String key,
SettableBlobMeta meta) |
void |
Nimbus.setBlobMeta(String key,
SettableBlobMeta meta) |
Modifier and Type | Method and Description |
---|---|
SettableBlobMeta |
SettableBlobMeta.deepCopy() |
SettableBlobMeta |
Nimbus.beginCreateBlob_args.get_meta() |
SettableBlobMeta |
Nimbus.setBlobMeta_args.get_meta() |
SettableBlobMeta |
ReadableBlobMeta.get_settable() |
Modifier and Type | Method and Description |
---|---|
String |
Nimbus.Iface.beginCreateBlob(String key,
SettableBlobMeta meta) |
String |
Nimbus.Client.beginCreateBlob(String key,
SettableBlobMeta meta) |
void |
Nimbus.AsyncIface.beginCreateBlob(String key,
SettableBlobMeta meta,
org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) |
void |
Nimbus.AsyncClient.beginCreateBlob(String key,
SettableBlobMeta meta,
org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) |
int |
SettableBlobMeta.compareTo(SettableBlobMeta other) |
boolean |
SettableBlobMeta.equals(SettableBlobMeta that) |
void |
Nimbus.Client.send_beginCreateBlob(String key,
SettableBlobMeta meta) |
void |
Nimbus.Client.send_setBlobMeta(String key,
SettableBlobMeta meta) |
void |
Nimbus.beginCreateBlob_args.set_meta(SettableBlobMeta meta) |
void |
Nimbus.setBlobMeta_args.set_meta(SettableBlobMeta meta) |
void |
ReadableBlobMeta.set_settable(SettableBlobMeta settable) |
void |
Nimbus.Iface.setBlobMeta(String key,
SettableBlobMeta meta) |
void |
Nimbus.Client.setBlobMeta(String key,
SettableBlobMeta meta) |
void |
Nimbus.AsyncIface.setBlobMeta(String key,
SettableBlobMeta meta,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
Nimbus.AsyncClient.setBlobMeta(String key,
SettableBlobMeta meta,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
Constructor and Description |
---|
beginCreateBlob_args(String key,
SettableBlobMeta meta) |
beginCreateBlob_call(String key,
SettableBlobMeta meta,
org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
ReadableBlobMeta(SettableBlobMeta settable,
long version) |
setBlobMeta_args(String key,
SettableBlobMeta meta) |
setBlobMeta_call(String key,
SettableBlobMeta meta,
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) |
SettableBlobMeta(SettableBlobMeta other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
SettableBlobMeta |
HdfsBlobStoreFile.getMetadata() |
Modifier and Type | Method and Description |
---|---|
AtomicOutputStream |
HdfsBlobStore.createBlob(String key,
SettableBlobMeta meta,
Subject who) |
AtomicOutputStream |
HdfsClientBlobStore.createBlobToExtend(String key,
SettableBlobMeta meta) |
void |
HdfsBlobStore.setBlobMeta(String key,
SettableBlobMeta meta,
Subject who) |
void |
HdfsClientBlobStore.setBlobMetaToExtend(String key,
SettableBlobMeta meta) |
void |
HdfsBlobStoreFile.setMetadata(SettableBlobMeta meta) |
void |
HdfsBlobStore.writeMetadata(String key,
SettableBlobMeta meta) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.