Uses of Class
org.apache.storm.generated.KeyNotFoundException
Packages that use KeyNotFoundException
Package
Description
-
Uses of KeyNotFoundException in org.apache.storm
Methods in org.apache.storm that throw KeyNotFoundExceptionModifier and TypeMethodDescriptionLocalCluster.beginBlobDownload(String key) LocalCluster.beginUpdateBlob(String key) voidLocalCluster.deleteBlob(String key) LocalCluster.getBlobMeta(String key) intLocalCluster.getBlobReplication(String key) voidLocalCluster.setBlobMeta(String key, SettableBlobMeta meta) intLocalCluster.updateBlobReplication(String key, int replication) -
Uses of KeyNotFoundException in org.apache.storm.blobstore
Methods in org.apache.storm.blobstore that throw KeyNotFoundExceptionModifier and TypeMethodDescriptionbooleanLocalFsBlobStore.checkForBlobOrDownload(String key) protected static voidMigrateBlobs.copyBlobStoreKeys(BlobStore bsFrom, Subject whoFrom, BlobStore bsTo, Subject whoTo) protected static voidMigrateBlobs.deleteAllBlobStoreKeys(BlobStore bs, Subject who) abstract voidBlobStore.deleteBlob(String key, Subject who) Deletes the blob data and metadata.abstract voidClientBlobStore.deleteBlob(String key) Client facing API to delete a blob.voidLocalFsBlobStore.deleteBlob(String key, Subject who) voidLocalModeClientBlobStore.deleteBlob(String key) voidNimbusBlobStore.deleteBlob(String key) abstract InputStreamWithMetaGets the InputStream to read the blob details.abstract InputStreamWithMetaClient facing API to read a blob.abstract ReadableBlobMetaBlobStore.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 ReadableBlobMetaClientBlobStore.getBlobMeta(String key) Client facing API to read the metadata information.LocalFsBlobStore.getBlobMeta(String key, Subject who) LocalModeClientBlobStore.getBlobMeta(String key) NimbusBlobStore.getBlobMeta(String key) abstract intClientBlobStore.getBlobReplication(String key) Client facing API to read the replication of a blob.intLocalModeClientBlobStore.getBlobReplication(String key) intNimbusBlobStore.getBlobReplication(String key) intKeySequenceNumber.getKeySequenceNumber(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient) byte[]Wrapper around readBlobTo which returns a ByteArray output stream.voidBlobStore.readBlobTo(String key, OutputStream out, Subject who) Reads the blob from the blob store and writes it into the output stream.abstract voidBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who) Sets the metadata with renewed acls for the blob.final voidClientBlobStore.setBlobMeta(String key, SettableBlobMeta meta) Client facing API to set the metadata for a blob.voidLocalFsBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who) protected abstract voidClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) Client facing API to set the metadata for a blob.protected voidLocalModeClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) protected voidNimbusBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) voidBlobStore.startSyncBlobs()Start the syncing blobs between the local running instance of the BlobStore and others.voidLocalFsBlobStore.startSyncBlobs()voidBlobStore.updateBlob(String key, byte[] data, Subject who) Wrapper called to create the blob which contains the byte data.abstract AtomicOutputStreamBlobStore.updateBlob(String key, Subject who) Updates the blob data.abstract AtomicOutputStreamClientBlobStore.updateBlob(String key) Client facing API to update a blob.LocalFsBlobStore.updateBlob(String key, Subject who) LocalModeClientBlobStore.updateBlob(String key) NimbusBlobStore.updateBlob(String key) abstract intBlobStore.updateBlobReplication(String key, int replication, Subject who) Modifies the replication factor of the blob.abstract intClientBlobStore.updateBlobReplication(String key, int replication) Client facing API to update the replication of a blob.intLocalFsBlobStore.updateBlobReplication(String key, int replication, Subject who) intLocalModeClientBlobStore.updateBlobReplication(String key, int replication) intNimbusBlobStore.updateBlobReplication(String key, int replication) -
Uses of KeyNotFoundException in org.apache.storm.daemon.nimbus
Methods in org.apache.storm.daemon.nimbus that throw KeyNotFoundExceptionModifier and TypeMethodDescriptionNimbus.beginBlobDownload(String key) Nimbus.beginUpdateBlob(String key) voidNimbus.deleteBlob(String key) voidTopoCache.deleteTopoConf(String topoId, Subject who) Delete a topology conf when we are done.voidTopoCache.deleteTopology(String topoId, Subject who) Delete a topology when we are done.Nimbus.getBlobMeta(String key) intNimbus.getBlobReplication(String key) static intNimbus.getVersionForKey(String key, NimbusInfo nimbusInfo, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient) TopoCache.readTopoConf(String topoId, Subject who) Read a topology conf.TopoCache.readTopology(String topoId, Subject who) Read a topology.voidNimbus.setBlobMeta(String key, SettableBlobMeta meta) intNimbus.updateBlobReplication(String key, int replication) voidUpdate an existing topology conf.voidTopoCache.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 KeyNotFoundExceptionModifier and TypeMethodDescriptionKeyNotFoundException.deepCopy()Nimbus.beginBlobDownload_result.get_knf()Nimbus.beginUpdateBlob_result.get_knf()Nimbus.deleteBlob_result.get_knf()Nimbus.getBlobMeta_result.get_knf()Nimbus.getBlobReplication_result.get_knf()Nimbus.setBlobMeta_result.get_knf()Nimbus.updateBlobReplication_result.get_knf()Methods in org.apache.storm.generated with parameters of type KeyNotFoundExceptionModifier and TypeMethodDescriptionintKeyNotFoundException.compareTo(KeyNotFoundException other) booleanKeyNotFoundException.equals(KeyNotFoundException that) voidNimbus.beginBlobDownload_result.set_knf(KeyNotFoundException knf) voidNimbus.beginUpdateBlob_result.set_knf(KeyNotFoundException knf) voidNimbus.deleteBlob_result.set_knf(KeyNotFoundException knf) voidNimbus.getBlobMeta_result.set_knf(KeyNotFoundException knf) voidNimbus.getBlobReplication_result.set_knf(KeyNotFoundException knf) voidNimbus.setBlobMeta_result.set_knf(KeyNotFoundException knf) voidNimbus.updateBlobReplication_result.set_knf(KeyNotFoundException knf) Methods in org.apache.storm.generated that throw KeyNotFoundExceptionModifier and TypeMethodDescriptionNimbus.Client.beginBlobDownload(String key) Nimbus.Iface.beginBlobDownload(String key) Nimbus.Client.beginUpdateBlob(String key) Nimbus.Iface.beginUpdateBlob(String key) voidNimbus.Client.deleteBlob(String key) voidNimbus.Iface.deleteBlob(String key) Nimbus.Client.getBlobMeta(String key) Nimbus.Iface.getBlobMeta(String key) intNimbus.Client.getBlobReplication(String key) intNimbus.Iface.getBlobReplication(String key) Nimbus.AsyncClient.beginBlobDownload_call.getResult()Nimbus.AsyncClient.beginUpdateBlob_call.getResult()Nimbus.AsyncClient.deleteBlob_call.getResult()Nimbus.AsyncClient.getBlobMeta_call.getResult()Nimbus.AsyncClient.getBlobReplication_call.getResult()Nimbus.AsyncClient.setBlobMeta_call.getResult()Nimbus.AsyncClient.updateBlobReplication_call.getResult()Nimbus.Client.recv_beginBlobDownload()Nimbus.Client.recv_beginUpdateBlob()voidNimbus.Client.recv_deleteBlob()Nimbus.Client.recv_getBlobMeta()intNimbus.Client.recv_getBlobReplication()voidNimbus.Client.recv_setBlobMeta()intNimbus.Client.recv_updateBlobReplication()voidNimbus.Client.setBlobMeta(String key, SettableBlobMeta meta) voidNimbus.Iface.setBlobMeta(String key, SettableBlobMeta meta) intNimbus.Client.updateBlobReplication(String key, int replication) intNimbus.Iface.updateBlobReplication(String key, int replication) Constructors in org.apache.storm.generated with parameters of type KeyNotFoundExceptionModifierConstructorDescriptionbeginBlobDownload_result(BeginDownloadResult success, AuthorizationException aze, KeyNotFoundException knf) beginUpdateBlob_result(String success, AuthorizationException aze, KeyNotFoundException knf) getBlobMeta_result(ReadableBlobMeta success, AuthorizationException aze, KeyNotFoundException knf) getBlobReplication_result(int success, AuthorizationException aze, KeyNotFoundException knf) Performs a deep copy on other.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 KeyNotFoundExceptionModifier and TypeMethodDescriptionvoidHdfsBlobStore.deleteBlob(String key, Subject who) voidHdfsClientBlobStore.deleteBlob(String key) HdfsBlobStore.getBlobMeta(String key, Subject who) HdfsClientBlobStore.getBlobMeta(String key) intHdfsBlobStore.getBlobReplication(String key, Subject who) intHdfsClientBlobStore.getBlobReplication(String key) voidHdfsBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who) voidHdfsClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) HdfsBlobStore.updateBlob(String key, Subject who) HdfsClientBlobStore.updateBlob(String key) intHdfsBlobStore.updateBlobReplication(String key, int replication, Subject who) intHdfsClientBlobStore.updateBlobReplication(String key, int replication) voidHdfsBlobStore.writeMetadata(String key, SettableBlobMeta meta) -
Uses of KeyNotFoundException in org.apache.storm.localizer
Methods in org.apache.storm.localizer that throw KeyNotFoundExceptionModifier and TypeMethodDescriptionprotected org.apache.storm.localizer.LocallyCachedBlob.DownloadMetaLocallyCachedBlob.fetch(ClientBlobStore store, String key, IOFunction<Long, Path> pathSupplier, IOFunction<File, OutputStream> outStreamSupplier) Helper function to download blob from blob store.longLocalizedResource.fetchUnzipToTemp(ClientBlobStore store) abstract longLocallyCachedBlob.fetchUnzipToTemp(ClientBlobStore store) Download the latest version to a temp location.longLocallyCachedTopologyBlob.fetchUnzipToTemp(ClientBlobStore store) longLocalizedResource.getRemoteVersion(ClientBlobStore store) abstract longLocallyCachedBlob.getRemoteVersion(ClientBlobStore store) Get the version of the blob in the blob store.longLocallyCachedTopologyBlob.getRemoteVersion(ClientBlobStore store) voidLocallyCachedBlob.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.utilsModifier and TypeClassDescriptionclassWraps the generated TException to allow getMessage() to return a valid string.Methods in org.apache.storm.utils that throw KeyNotFoundExceptionModifier and TypeMethodDescriptionstatic longServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb)