Package | Description |
---|---|
org.apache.storm.blobstore | |
org.apache.storm.hdfs.blobstore |
Modifier and Type | Class and Description |
---|---|
protected class |
BlobStore.BlobStoreFileOutputStream
Output stream implementation used for reading the metadata and data information.
|
class |
NimbusBlobStore.NimbusUploadAtomicOutputStream |
Modifier and Type | Method and Description |
---|---|
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) |
abstract AtomicOutputStream |
ClientBlobStore.updateBlob(String key)
Client facing API to update a blob.
|
AtomicOutputStream |
LocalModeClientBlobStore.updateBlob(String key) |
AtomicOutputStream |
NimbusBlobStore.updateBlob(String key) |
AtomicOutputStream |
LocalFsBlobStore.updateBlob(String key,
Subject who) |
abstract AtomicOutputStream |
BlobStore.updateBlob(String key,
Subject who)
Updates the blob data.
|
Modifier and Type | Method and Description |
---|---|
AtomicOutputStream |
HdfsBlobStore.createBlob(String key,
SettableBlobMeta meta,
Subject who) |
AtomicOutputStream |
HdfsClientBlobStore.createBlobToExtend(String key,
SettableBlobMeta meta) |
AtomicOutputStream |
HdfsClientBlobStore.updateBlob(String key) |
AtomicOutputStream |
HdfsBlobStore.updateBlob(String key,
Subject who) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.