List relevant keys. @return all keys that are available for reading @throws IOException on any error

Loads the last saved checkpoint state the from persistent storage.

Load some part of state KVs from storage and returns iterator of cached data from storage. @return Iterator of loaded state KVs

## Repartitioning Operation. <p>Use random round robin algorithm to evenly redistribute tuples across all target partitions, with a preference for lo

Log a bunch of stuff for debugging.

Use this method to log the current component assignments on the Node. Useful for debugging and tests.

Given an appender name, as configured, get the parent directory of the appender's log file. Note that if anything goes wrong, this will throw an Error

Hadoop does not just go off of a TGT, it needs a bit more. This should fill in the rest. @param subject the subject that should have a TGT in it.

Flux main entry point. @param args command line arguments @throws Exception if parsing/topology creation fails

Constructs a TimeCacheMap instance with a blobstore timeout and no callback function. @param conf the config to use @return the newly created TimeCac

Checks that the dependencies in the storm-dist/binary license report are mentioned in LICENSE-binary, and vice versa.

If the topology has at least one stateful bolt add a {@link CheckpointSpout} component to the topology.

If the topology has at least one stateful bolt all the non-stateful bolts are wrapped in {@link CheckpointTupleForwarder} so that the checkpoint tuple

merge accumulated bolt stats with pre-merged component stats. @param accBoltStats accumulated bolt stats @param boltStats pre-merged component sta

merge accumulated bolt stats with pre-merged component stats.

merge accumulated bolt stats with new bolt stats. @param accBoltStats accumulated bolt stats @param boltStats new input bolt stats @return merged

merge accumulated bolt stats with new bolt stats.

this method merges 2 two-level-deep maps.

Merge extra_groups entries into base_groups for coordinates in extra_coordinates that are not already present in base_groups. Returns a new l