Called at least once before {@link ShellLogHandler#log} for each spout and bolt. Allows implementing classes to save information about the current run

@see ComponentType

Test Cluster.getAssignedMemoryForSlot with a single config value set. @param key - the config key to set @param value - the config value to set @param

Sync the remote state store assignments to local backend, used when master gains leadership, see {@code org.apache.storm.nimbus.LeaderListenerCallback

Serializes the given TopicPartition to Map so Trident can serialize it to JSON.

Translates a normalized resource map to an array of resource values. Each resource name will be assigned an index in the array, which is guaranteed to

Non-blocking call, returns false if full.

Update the heartbeats for a given worker. @param workerHeartbeat the heartbeats from the worker. @param taskTimeoutSecs the timeout we should be look