| 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 | 
|---|---|
ReadableBlobMeta | 
LocalCluster.getBlobMeta(String key)  | 
| Modifier and Type | Method and Description | 
|---|---|
abstract ReadableBlobMeta | 
ClientBlobStore.getBlobMeta(String key)
Client facing API to read the metadata information. 
 | 
ReadableBlobMeta | 
LocalModeClientBlobStore.getBlobMeta(String key)  | 
ReadableBlobMeta | 
NimbusBlobStore.getBlobMeta(String key)  | 
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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ReadableBlobMeta | 
Nimbus.getBlobMeta(String key)  | 
| Modifier and Type | Method and Description | 
|---|---|
ReadableBlobMeta | 
ReadableBlobMeta.deepCopy()  | 
ReadableBlobMeta | 
Nimbus.getBlobMeta_result.get_success()  | 
ReadableBlobMeta | 
Nimbus.Iface.getBlobMeta(String key)  | 
ReadableBlobMeta | 
Nimbus.Client.getBlobMeta(String key)  | 
ReadableBlobMeta | 
Nimbus.AsyncClient.getBlobMeta_call.getResult()  | 
ReadableBlobMeta | 
Nimbus.Client.recv_getBlobMeta()  | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> | 
Nimbus.AsyncProcessor.getBlobMeta.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
                int seqid)  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
ReadableBlobMeta.compareTo(ReadableBlobMeta other)  | 
boolean | 
ReadableBlobMeta.equals(ReadableBlobMeta that)  | 
void | 
Nimbus.getBlobMeta_result.set_success(ReadableBlobMeta success)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Nimbus.AsyncIface.getBlobMeta(String key,
           org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler)  | 
void | 
Nimbus.AsyncClient.getBlobMeta(String key,
           org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler)  | 
void | 
Nimbus.AsyncProcessor.getBlobMeta.start(I iface,
     Nimbus.getBlobMeta_args args,
     org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler)  | 
| Constructor and Description | 
|---|
getBlobMeta_result(ReadableBlobMeta success,
                  AuthorizationException aze,
                  KeyNotFoundException knf)  | 
ReadableBlobMeta(ReadableBlobMeta other)
Performs a deep copy on other. 
 | 
| Constructor and Description | 
|---|
getBlobMeta_call(String key,
                org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler,
                org.apache.storm.thrift.async.TAsyncClient client,
                org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
                org.apache.storm.thrift.transport.TNonblockingTransport transport)  | 
| Modifier and Type | Method and Description | 
|---|---|
ReadableBlobMeta | 
HdfsClientBlobStore.getBlobMeta(String key)  | 
ReadableBlobMeta | 
HdfsBlobStore.getBlobMeta(String key,
           Subject who)  | 
| Modifier and Type | Method and Description | 
|---|---|
static boolean | 
ServerUtils.canUserReadBlob(ReadableBlobMeta meta,
               String user,
               Map<String,Object> conf)  | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.