Returns an iterator over the events in the window. <p> <b>Note: </b> This is only supported when using windowing with persistence {@link BaseStatefulW

Extract the key from the input Tuple.

Function to create a keystore and return the keystore file. @param keyStorePass The keystore password. @return The keystore file @throws CertificateEx

Get the last update time of any blob. @return the last updated time of blobs within the blobstore. @throws IOException on any error

gets the key just larger than the last possible key value for the desired key type. @return the last key

Get the latch and indicate that you want to block the blob being changed. @return the latch to use when you are ready.

Get the layers information from the manifest. The layers should be returned in the order in which they appear in the manifest @param manifest the mani

Returns login object. @return login

Get logviewer port depending on whether the logviewer is secure or not. @param config Storm config. @return appropriate port.

Maximum number of isolated nodes being requested based on the topology configuration {@link Config#TOPOLOGY_ISOLATED_MACHINES}.

Get the current memory reservation of this container.

Get the current memory usage of the a given worker. @param user the user that the worker is running as @param workerId the id of the worker @param por

Get the current memory usage of this container.

Get the full name of the user.

Get the component name to executor list for executors that need to be scheduled. @param topology the topology this is for @return a component-id -> e

Computes the next window by scanning the events in the window and finds the next aligned window between the startTs and endTs. Return the end ts of th