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

Copyright © 2021 The Apache Software Foundation. All rights reserved.