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 and 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 and 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	ClientBlobStore.deleteBlob(String key) Client facing API to delete a blob.
void	LocalModeClientBlobStore.deleteBlob(String key)
void	NimbusBlobStore.deleteBlob(String key)
void	LocalFsBlobStore.deleteBlob(String key, Subject who)
abstract void	BlobStore.deleteBlob(String key, Subject who) Deletes the blob data and metadata.
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.
abstract ReadableBlobMeta	ClientBlobStore.getBlobMeta(String key) Client facing API to read the metadata information.
ReadableBlobMeta	LocalModeClientBlobStore.getBlobMeta(String key)
ReadableBlobMeta	NimbusBlobStore.getBlobMeta(String key)
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.
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.
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 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	LocalFsBlobStore.startSyncBlobs()
void	BlobStore.startSyncBlobs() Start the syncing blobs between the local running instance of the BlobStore and others.
abstract AtomicOutputStream	ClientBlobStore.updateBlob(String key) Client facing API to update a blob.
AtomicOutputStream	LocalModeClientBlobStore.updateBlob(String key)
AtomicOutputStream	NimbusBlobStore.updateBlob(String key)
void	BlobStore.updateBlob(String key, byte[] data, Subject who) Wrapper called to create the blob which contains the byte data.
AtomicOutputStream	LocalFsBlobStore.updateBlob(String key, Subject who)
abstract AtomicOutputStream	BlobStore.updateBlob(String key, Subject who) Updates the blob data.
abstract int	ClientBlobStore.updateBlobReplication(String key, int replication) Client facing API to update the replication of a blob.
int	LocalModeClientBlobStore.updateBlobReplication(String key, int replication)
int	NimbusBlobStore.updateBlobReplication(String key, int replication)
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.daemon.nimbus

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

Modifier and Type	Method and 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 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, 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 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
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.
abstract long	LocallyCachedBlob.fetchUnzipToTemp(ClientBlobStore store) Download the latest version to a temp location.
long	LocallyCachedTopologyBlob.fetchUnzipToTemp(ClientBlobStore store)
long	LocalizedResource.fetchUnzipToTemp(ClientBlobStore store)
abstract long	LocallyCachedBlob.getRemoteVersion(ClientBlobStore store) Get the version of the blob in the blob store.
long	LocallyCachedTopologyBlob.getRemoteVersion(ClientBlobStore store)
long	LocalizedResource.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 and 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 and Description
static long	ServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb)