# 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)`