Return true if this blob is actively being used, else false (meaning it can be deleted, but might not be).

Returns true if the processing is in a windowed context and should wait for punctuation before emitting results. @return whether this is a windowed c

nullToZero. @param value value @return nullToZero

Validates key checking for potentially harmful patterns. @param key Key for the blob

Release any resources held by this emitter.

Check if the suffix ends in pkcs12/p12/jks (case insensitive) and return PKCS12 ot JKS. If not, then return null. The path can be url to a resource si

Returns true if field owner is set (has been assigned a value) and false otherwise

Returns a stream consisting of the trident tuples of this stream, additionally performing the provided action on each trident tuple as they are consum

Sets a context in the eviction policy that can be used while evicting the events. E.g. For TimeEvictionPolicy, this could be used to set the reference

Set a {@link KafkaConsumer} property.

set scheduler status for a topology.

Declare the output schema for all the streams of this topology. @param declarer this is used to declare output stream ids, output fields, and whether

Convert a float to a string for display. @param n the value to format. @return the string ready for display.

Get the last time that this used for LRU calculations.

Applies a parallelism hint to a stream.

Register any serializers needed with the kryo instance. @param kryo what to register the serializers with.

resets the trigger policy.

Determines the offset of the next fetch. Will use the firstPollOffsetStrategy if this is the first poll for the topic partition. Otherwise the next of

Get a storm base for a topology. @param stormId the id of the topology @param callback something to call if the data changes (best effort) @return t

Mark that a given port and assignment are using this. @param pna the slot and assignment that are using this blob. @param cb an optional callback in

Close the connection to the data store.

Find the _Fields constant that matches fieldId, or null if its not found.

Declare configuration specific to this component. Only a subset of the "topology. " configs can be overridden. The component configuration can be furt

Returns defined data type. @return data type

Returns the compiled topology that contains ackers and metrics consumsers. Compare {@link #getUserTopology(String id)}. @param id

Gets total resources for this node.

Stores a metric in the store. @param metric Metric to store @throws MetricException on error

Returns true if field chunk is set (has been assigned a value) and false otherwise

Returns true if field component_debug is set (has been assigned a value) and false otherwise

Returns true if field component_id is set (has been assigned a value) and false otherwise