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

Packages that use KeyNotFoundException

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.localizer
org.apache.storm.utils

Uses of KeyNotFoundException in org.apache.storm

Methods in org.apache.storm that throw KeyNotFoundException

Modifier and Type	Method	Description
BeginDownloadResult	LocalCluster.beginBlobDownload(String key)
String	LocalCluster.beginUpdateBlob(String key)
void	LocalCluster.deleteBlob(String key)
ReadableBlobMeta	LocalCluster.getBlobMeta(String key)
int	LocalCluster.getBlobReplication(String key)
void	LocalCluster.setBlobMeta(String key, SettableBlobMeta meta)
int	LocalCluster.updateBlobReplication(String key, int replication)

Uses of KeyNotFoundException in org.apache.storm.blobstore

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

Modifier and Type	Method	Description
boolean	LocalFsBlobStore.checkForBlobOrDownload(String key)
protected static void	MigrateBlobs.copyBlobStoreKeys(BlobStore bsFrom, Subject whoFrom, BlobStore bsTo, Subject whoTo)
protected static void	MigrateBlobs.deleteAllBlobStoreKeys(BlobStore bs, Subject who)
abstract void	BlobStore.deleteBlob(String key, Subject who)	Deletes the blob data and metadata.
abstract void	ClientBlobStore.deleteBlob(String key)	Client facing API to delete a blob.
void	LocalFsBlobStore.deleteBlob(String key, Subject who)
void	LocalModeClientBlobStore.deleteBlob(String key)
void	NimbusBlobStore.deleteBlob(String key)
abstract InputStreamWithMeta	BlobStore.getBlob(String key, Subject who)	Gets the InputStream to read the blob details.
abstract InputStreamWithMeta	ClientBlobStore.getBlob(String key)	Client facing API to read a blob.
InputStreamWithMeta	LocalFsBlobStore.getBlob(String key, Subject who)
InputStreamWithMeta	LocalModeClientBlobStore.getBlob(String key)
InputStreamWithMeta	NimbusBlobStore.getBlob(String key)
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.
abstract ReadableBlobMeta	ClientBlobStore.getBlobMeta(String key)	Client facing API to read the metadata information.
ReadableBlobMeta	LocalFsBlobStore.getBlobMeta(String key, Subject who)
ReadableBlobMeta	LocalModeClientBlobStore.getBlobMeta(String key)
ReadableBlobMeta	NimbusBlobStore.getBlobMeta(String key)
abstract int	ClientBlobStore.getBlobReplication(String key)	Client facing API to read the replication of a blob.
int	LocalModeClientBlobStore.getBlobReplication(String key)
int	NimbusBlobStore.getBlobReplication(String key)
int	KeySequenceNumber.getKeySequenceNumber(org.apache.storm.shade.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.
abstract void	BlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who)	Sets the metadata with renewed acls for the blob.
final 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)
protected abstract void	ClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta)	Client facing API to set the metadata for a blob.
protected void	LocalModeClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta)
protected void	NimbusBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta)
void	BlobStore.startSyncBlobs()	Start the syncing blobs between the local running instance of the BlobStore and others.
void	LocalFsBlobStore.startSyncBlobs()
void	BlobStore.updateBlob(String key, byte[] data, Subject who)	Wrapper called to create the blob which contains the byte data.
abstract AtomicOutputStream	BlobStore.updateBlob(String key, Subject who)	Updates the blob data.
abstract AtomicOutputStream	ClientBlobStore.updateBlob(String key)	Client facing API to update a blob.
AtomicOutputStream	LocalFsBlobStore.updateBlob(String key, Subject who)
AtomicOutputStream	LocalModeClientBlobStore.updateBlob(String key)
AtomicOutputStream	NimbusBlobStore.updateBlob(String key)
abstract int	BlobStore.updateBlobReplication(String key, int replication, Subject who)	Modifies the replication factor of the blob.
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)
int	LocalModeClientBlobStore.updateBlobReplication(String key, int replication)
int	NimbusBlobStore.updateBlobReplication(String key, int replication)

Uses of KeyNotFoundException in org.apache.storm.daemon.nimbus

Methods in org.apache.storm.daemon.nimbus that throw KeyNotFoundException

Modifier and Type	Method	Description
BeginDownloadResult	Nimbus.beginBlobDownload(String key)
String	Nimbus.beginUpdateBlob(String key)
void	Nimbus.deleteBlob(String key)
void	TopoCache.deleteTopoConf(String topoId, Subject who)	Delete a topology conf when we are done.
void	TopoCache.deleteTopology(String topoId, Subject who)	Delete a topology when we are done.
ReadableBlobMeta	Nimbus.getBlobMeta(String key)
int	Nimbus.getBlobReplication(String key)
static int	Nimbus.getVersionForKey(String key, NimbusInfo nimbusInfo, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient)
Map<String,Object>	TopoCache.readTopoConf(String topoId, Subject who)	Read a topology conf.
StormTopology	TopoCache.readTopology(String topoId, Subject who)	Read a topology.
void	Nimbus.setBlobMeta(String key, SettableBlobMeta meta)
int	Nimbus.updateBlobReplication(String key, int replication)
void	TopoCache.updateTopoConf(String topoId, Subject who, Map<String,Object> topoConf)	Update an existing topology conf.
void	TopoCache.updateTopology(String topoId, Subject who, StormTopology topo)	Update an existing topology .

Uses of KeyNotFoundException in org.apache.storm.generated

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

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

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

Modifier and Type	Method	Description
int	KeyNotFoundException.compareTo(KeyNotFoundException other)
boolean	KeyNotFoundException.equals(KeyNotFoundException that)
void	Nimbus.beginBlobDownload_result.set_knf(KeyNotFoundException knf)
void	Nimbus.beginUpdateBlob_result.set_knf(KeyNotFoundException knf)
void	Nimbus.deleteBlob_result.set_knf(KeyNotFoundException knf)
void	Nimbus.getBlobMeta_result.set_knf(KeyNotFoundException knf)
void	Nimbus.getBlobReplication_result.set_knf(KeyNotFoundException knf)
void	Nimbus.setBlobMeta_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	Description
BeginDownloadResult	Nimbus.Client.beginBlobDownload(String key)
BeginDownloadResult	Nimbus.Iface.beginBlobDownload(String key)
String	Nimbus.Client.beginUpdateBlob(String key)
String	Nimbus.Iface.beginUpdateBlob(String key)
void	Nimbus.Client.deleteBlob(String key)
void	Nimbus.Iface.deleteBlob(String key)
ReadableBlobMeta	Nimbus.Client.getBlobMeta(String key)
ReadableBlobMeta	Nimbus.Iface.getBlobMeta(String key)
int	Nimbus.Client.getBlobReplication(String key)
int	Nimbus.Iface.getBlobReplication(String key)
BeginDownloadResult	Nimbus.AsyncClient.beginBlobDownload_call.getResult()
String	Nimbus.AsyncClient.beginUpdateBlob_call.getResult()
Void	Nimbus.AsyncClient.deleteBlob_call.getResult()
ReadableBlobMeta	Nimbus.AsyncClient.getBlobMeta_call.getResult()
Integer	Nimbus.AsyncClient.getBlobReplication_call.getResult()
Void	Nimbus.AsyncClient.setBlobMeta_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.Client.setBlobMeta(String key, SettableBlobMeta meta)
void	Nimbus.Iface.setBlobMeta(String key, SettableBlobMeta meta)
int	Nimbus.Client.updateBlobReplication(String key, int replication)
int	Nimbus.Iface.updateBlobReplication(String key, int replication)

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

Modifier	Constructor	Description
	beginBlobDownload_result(BeginDownloadResult success, AuthorizationException aze, KeyNotFoundException knf)
	beginUpdateBlob_result(String success, AuthorizationException aze, KeyNotFoundException knf)
	deleteBlob_result(AuthorizationException aze, KeyNotFoundException knf, IllegalStateException ise)
	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	Description
void	HdfsBlobStore.deleteBlob(String key, Subject who)
void	HdfsClientBlobStore.deleteBlob(String key)
InputStreamWithMeta	HdfsBlobStore.getBlob(String key, Subject who)
InputStreamWithMeta	HdfsClientBlobStore.getBlob(String key)
ReadableBlobMeta	HdfsBlobStore.getBlobMeta(String key, Subject who)
ReadableBlobMeta	HdfsClientBlobStore.getBlobMeta(String key)
int	HdfsBlobStore.getBlobReplication(String key, Subject who)
int	HdfsClientBlobStore.getBlobReplication(String key)
void	HdfsBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who)
void	HdfsClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta)
AtomicOutputStream	HdfsBlobStore.updateBlob(String key, Subject who)
AtomicOutputStream	HdfsClientBlobStore.updateBlob(String key)
int	HdfsBlobStore.updateBlobReplication(String key, int replication, Subject who)
int	HdfsClientBlobStore.updateBlobReplication(String key, int replication)
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	Description
protected org.apache.storm.localizer.LocallyCachedBlob.DownloadMeta	LocallyCachedBlob.fetch(ClientBlobStore store, String key, IOFunction<Long,Path> pathSupplier, IOFunction<File,OutputStream> outStreamSupplier)	Helper function to download blob from blob store.
long	LocalizedResource.fetchUnzipToTemp(ClientBlobStore store)
abstract long	LocallyCachedBlob.fetchUnzipToTemp(ClientBlobStore store)	Download the latest version to a temp location.
long	LocallyCachedTopologyBlob.fetchUnzipToTemp(ClientBlobStore store)
long	LocalizedResource.getRemoteVersion(ClientBlobStore store)
abstract long	LocallyCachedBlob.getRemoteVersion(ClientBlobStore store)	Get the version of the blob in the blob store.
long	LocallyCachedTopologyBlob.getRemoteVersion(ClientBlobStore store)
void	LocallyCachedBlob.update(ClientBlobStore blobStore, long remoteBlobstoreUpdateTime)	Checks and downloads a blob locally as necessary.

Uses of KeyNotFoundException in org.apache.storm.utils

Subclasses of KeyNotFoundException in org.apache.storm.utils

Modifier and Type	Class	Description
class	WrappedKeyNotFoundException	Wraps the generated TException to allow getMessage() to return a valid string.

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

Modifier and Type	Method	Description
static long	ServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb)