Package | Description |
---|---|
org.apache.storm.blobstore | |
org.apache.storm.hdfs.blobstore |
Modifier and Type | Class and Description |
---|---|
protected class |
BlobStore.BlobStoreFileInputStream
Input stream implementation used for writing both the metadata containing the acl information and the blob data.
|
class |
NimbusBlobStore.NimbusDownloadInputStream |
Modifier and Type | Method and Description |
---|---|
abstract InputStreamWithMeta |
ClientBlobStore.getBlob(String key)
Client facing API to read a blob.
|
InputStreamWithMeta |
LocalModeClientBlobStore.getBlob(String key) |
InputStreamWithMeta |
NimbusBlobStore.getBlob(String key) |
InputStreamWithMeta |
LocalFsBlobStore.getBlob(String key,
Subject who) |
abstract InputStreamWithMeta |
BlobStore.getBlob(String key,
Subject who)
Gets the InputStream to read the blob details.
|
Modifier and Type | Method and Description |
---|---|
InputStreamWithMeta |
HdfsClientBlobStore.getBlob(String key) |
InputStreamWithMeta |
HdfsBlobStore.getBlob(String key,
Subject who) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.