initializes member variables.

Initialize the state of the processor with the given {@link KeyValueState}. @param keyValueState the key-value state

Load and initialize any resources into window manager before windowing for component/task is activated.

Initialize the flag to true if specified topology uses SharedOffHeapNodeMemory, false otherwise. @param td TopologyDetails to examine

Create metadata for this particular transaction id which has never been emitted before. The metadata should contain whatever is necessary to be able t

Initialize a fake config. @return conf

Invokes configuration methods on an class instance. @param bean the bean/component definition @param instance the class instance being operated on @pa

Invoke submitter hook. @throws SubmitterHookException This is thrown when any Exception occurs during initialization or invocation of registered {@lin

Flag to indicate if the assignments synced successfully, see {@link IStormClusterState#syncRemoteAssignments(Map)}. @return true if is synced success

Check if a given host is blacklisted. @param host the name of the host @return true if it is else false.

Emits a tuple if it is not a null tuple, or if the spout is configured to emit null tuples.

Check whether end of data is reached from storage state KVs. @return whether end of data is reached from storage state KVs

Convenience method for data.stream.allMatch(pred).

Check if any constraints are violated if exec is scheduled on worker. @return true if scheduling exec on worker does not violate any constraints, retu

Check whether spout is exhausted. @return true if all the tuples have been completed else false.

Check whether full. @return true if this batch used up allowed buffer size

Looks ahead to see if the GZIP magic constant is heading {@code bytes}.

Decide if the heartbeats is recovered for a master, will wait for all the assignments nodes to recovery, every node will take care its node heartbeats

Check local override. @return true of new clients will be overridden to connect to a local cluster and not the configured remote cluster