| 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 AtomicOutputStream | LocalModeClientBlobStore. createBlobToExtend(String key,
                  SettableBlobMeta meta) | 
| 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 | 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 void | LocalModeClientBlobStore. setBlobMetaToExtend(String key,
                   SettableBlobMeta meta) | 
| 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. | 
| 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 © 2020 The Apache Software Foundation. All rights reserved.