Uses of Class
org.apache.storm.generated.KeyNotFoundException

Packages that use KeyNotFoundException

Package	Description
org.apache.storm.blobstore
org.apache.storm.generated
org.apache.storm.hdfs.blobstore
org.apache.storm.localizer
org.apache.storm.utils

Uses of KeyNotFoundException in org.apache.storm.blobstore

Methods in org.apache.storm.blobstore that throw KeyNotFoundException

Modifier and Type	Method and Description
boolean	LocalFsBlobStore.checkForBlobOrDownload(String key)
void	NimbusBlobStore.deleteBlob(String key)
abstract void	ClientBlobStore.deleteBlob(String key) Client facing API to delete a blob.
void	LocalFsBlobStore.deleteBlob(String key, Subject who)
abstract void	BlobStore.deleteBlob(String key, Subject who) Deletes the blob data and metadata.
InputStreamWithMeta	NimbusBlobStore.getBlob(String key)
abstract InputStreamWithMeta	ClientBlobStore.getBlob(String key) Client facing API to read a blob.
InputStreamWithMeta	LocalFsBlobStore.getBlob(String key, Subject who)
abstract InputStreamWithMeta	BlobStore.getBlob(String key, Subject who) Gets the InputStream to read the blob details
ReadableBlobMeta	NimbusBlobStore.getBlobMeta(String key)
abstract ReadableBlobMeta	ClientBlobStore.getBlobMeta(String key) Client facing API to read the metadata information.
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.
int	NimbusBlobStore.getBlobReplication(String key)
abstract int	ClientBlobStore.getBlobReplication(String key) Client facing API to read the replication of a blob.
int	KeySequenceNumber.getKeySequenceNumber(org.apache.curator.framework.CuratorFramework zkClient)
byte[]	BlobStore.readBlob(String key, Subject who) Wrapper around readBlobTo which returns a ByteArray output stream.
void	BlobStore.readBlobTo(String key, OutputStream out, Subject who) Reads the blob from the blob store and writes it into the output stream.
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	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.
AtomicOutputStream	NimbusBlobStore.updateBlob(String key)
abstract AtomicOutputStream	ClientBlobStore.updateBlob(String key) Client facing API to update a blob.
AtomicOutputStream	LocalFsBlobStore.updateBlob(String key, Subject who)
abstract AtomicOutputStream	BlobStore.updateBlob(String key, Subject who) Updates the blob data.
int	NimbusBlobStore.updateBlobReplication(String key, int replication)
abstract int	ClientBlobStore.updateBlobReplication(String key, int replication) Client facing API to update the replication of a blob.
int	LocalFsBlobStore.updateBlobReplication(String key, int replication, Subject who)
abstract int	BlobStore.updateBlobReplication(String key, int replication, Subject who) Modifies the replication factor of the blob.

Uses of KeyNotFoundException in org.apache.storm.generated

Methods in org.apache.storm.generated that return KeyNotFoundException

Modifier and Type	Method and Description
KeyNotFoundException	KeyNotFoundException.deepCopy()
KeyNotFoundException	Nimbus.beginUpdateBlob_result.get_knf()
KeyNotFoundException	Nimbus.getBlobMeta_result.get_knf()
KeyNotFoundException	Nimbus.setBlobMeta_result.get_knf()
KeyNotFoundException	Nimbus.beginBlobDownload_result.get_knf()
KeyNotFoundException	Nimbus.deleteBlob_result.get_knf()
KeyNotFoundException	Nimbus.getBlobReplication_result.get_knf()
KeyNotFoundException	Nimbus.updateBlobReplication_result.get_knf()

Methods in org.apache.storm.generated with parameters of type KeyNotFoundException

Modifier and Type	Method and Description
int	KeyNotFoundException.compareTo(KeyNotFoundException other)
boolean	KeyNotFoundException.equals(KeyNotFoundException that)
void	Nimbus.beginUpdateBlob_result.set_knf(KeyNotFoundException knf)
void	Nimbus.getBlobMeta_result.set_knf(KeyNotFoundException knf)
void	Nimbus.setBlobMeta_result.set_knf(KeyNotFoundException knf)
void	Nimbus.beginBlobDownload_result.set_knf(KeyNotFoundException knf)
void	Nimbus.deleteBlob_result.set_knf(KeyNotFoundException knf)
void	Nimbus.getBlobReplication_result.set_knf(KeyNotFoundException knf)
void	Nimbus.updateBlobReplication_result.set_knf(KeyNotFoundException knf)

Methods in org.apache.storm.generated that throw KeyNotFoundException

Modifier and Type	Method and Description
BeginDownloadResult	Nimbus.Iface.beginBlobDownload(String key)
BeginDownloadResult	Nimbus.Client.beginBlobDownload(String key)
String	Nimbus.Iface.beginUpdateBlob(String key)
String	Nimbus.Client.beginUpdateBlob(String key)
void	Nimbus.Iface.deleteBlob(String key)
void	Nimbus.Client.deleteBlob(String key)
ReadableBlobMeta	Nimbus.Iface.getBlobMeta(String key)
ReadableBlobMeta	Nimbus.Client.getBlobMeta(String key)
int	Nimbus.Iface.getBlobReplication(String key)
int	Nimbus.Client.getBlobReplication(String key)
String	Nimbus.AsyncClient.beginUpdateBlob_call.getResult()
ReadableBlobMeta	Nimbus.AsyncClient.getBlobMeta_call.getResult()
Void	Nimbus.AsyncClient.setBlobMeta_call.getResult()
BeginDownloadResult	Nimbus.AsyncClient.beginBlobDownload_call.getResult()
Void	Nimbus.AsyncClient.deleteBlob_call.getResult()
Integer	Nimbus.AsyncClient.getBlobReplication_call.getResult()
Integer	Nimbus.AsyncClient.updateBlobReplication_call.getResult()
BeginDownloadResult	Nimbus.Client.recv_beginBlobDownload()
String	Nimbus.Client.recv_beginUpdateBlob()
void	Nimbus.Client.recv_deleteBlob()
ReadableBlobMeta	Nimbus.Client.recv_getBlobMeta()
int	Nimbus.Client.recv_getBlobReplication()
void	Nimbus.Client.recv_setBlobMeta()
int	Nimbus.Client.recv_updateBlobReplication()
void	Nimbus.Iface.setBlobMeta(String key, SettableBlobMeta meta)
void	Nimbus.Client.setBlobMeta(String key, SettableBlobMeta meta)
int	Nimbus.Iface.updateBlobReplication(String key, int replication)
int	Nimbus.Client.updateBlobReplication(String key, int replication)

Constructors in org.apache.storm.generated with parameters of type KeyNotFoundException

Constructor and Description
beginBlobDownload_result(BeginDownloadResult success, AuthorizationException aze, KeyNotFoundException knf)
beginUpdateBlob_result(String success, AuthorizationException aze, KeyNotFoundException knf)
deleteBlob_result(AuthorizationException aze, KeyNotFoundException knf)
getBlobMeta_result(ReadableBlobMeta success, AuthorizationException aze, KeyNotFoundException knf)
getBlobReplication_result(int success, AuthorizationException aze, KeyNotFoundException knf)
KeyNotFoundException(KeyNotFoundException other) Performs a deep copy on other.
setBlobMeta_result(AuthorizationException aze, KeyNotFoundException knf)
updateBlobReplication_result(int success, AuthorizationException aze, KeyNotFoundException knf)

Uses of KeyNotFoundException in org.apache.storm.hdfs.blobstore

Methods in org.apache.storm.hdfs.blobstore that throw KeyNotFoundException

Modifier and Type	Method and Description
void	HdfsClientBlobStore.deleteBlob(String key)
void	HdfsBlobStore.deleteBlob(String key, Subject who)
InputStreamWithMeta	HdfsClientBlobStore.getBlob(String key)
InputStreamWithMeta	HdfsBlobStore.getBlob(String key, Subject who)
ReadableBlobMeta	HdfsClientBlobStore.getBlobMeta(String key)
ReadableBlobMeta	HdfsBlobStore.getBlobMeta(String key, Subject who)
int	HdfsClientBlobStore.getBlobReplication(String key)
int	HdfsBlobStore.getBlobReplication(String key, Subject who)
void	HdfsBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who)
void	HdfsClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta)
AtomicOutputStream	HdfsClientBlobStore.updateBlob(String key)
AtomicOutputStream	HdfsBlobStore.updateBlob(String key, Subject who)
int	HdfsClientBlobStore.updateBlobReplication(String key, int replication)
int	HdfsBlobStore.updateBlobReplication(String key, int replication, Subject who)
void	HdfsBlobStore.writeMetadata(String key, SettableBlobMeta meta)

Uses of KeyNotFoundException in org.apache.storm.localizer

Methods in org.apache.storm.localizer that throw KeyNotFoundException

Modifier and Type	Method and Description
LocalizedResource	Localizer.getBlob(LocalResource localResource, String user, String topo, File userFileDir) This function either returns the blob in the existing cache or if it doesn’t exist in the cache, it will download the blob and will block until the download is complete.
List<LocalizedResource>	Localizer.getBlobs(List<LocalResource> localResources, String user, String topo, File userFileDir) This function either returns the blobs in the existing cache or if they don’t exist in the cache, it downloads them in parallel (up to SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT) and will block until all of them have been downloaded
protected boolean	Localizer.isLocalizedResourceUpToDate(LocalizedResource lrsrc, ClientBlobStore blobstore)
void	Localizer.removeBlobReference(String key, String user, String topo, boolean uncompress)
List<LocalizedResource>	Localizer.updateBlobs(List<LocalResource> localResources, String user) This function updates blobs on the supervisor.

Uses of KeyNotFoundException in org.apache.storm.utils

Methods in org.apache.storm.utils that throw KeyNotFoundException

Modifier and Type	Method and Description
static void	Utils.downloadResourcesAsSupervisor(String key, String localFile, ClientBlobStore cb) Meant to be called only by the supervisor for stormjar/stormconf/stormcode files.
void	Utils.downloadResourcesAsSupervisorImpl(String key, String localFile, ClientBlobStore cb)
static long	Utils.nimbusVersionOfBlob(String key, ClientBlobStore cb)