Covert this into a Map config. @return this as a Map config.

Translate a <code>org.apache.storm.tuple.Tuple</code> object to a <code>jakarta.jms.Message</code> object.

Return these resources as a normalized map. @return the normalized map.

Converts return value from Redis to a list of storm values that can be emitted. @param input the input tuple. @param value Redis query response value.

Converts a DB row to a list of storm values that can be emitted. This is done to allow a single storm input tuple and a single DB row to result in mul

* Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this

Returns a map like {nodeCount: numberOfNodesWithThatCount}.

Translates an array of resource values to a normalized resource map. @param resources The resource array to translate @return The normalized resource

Un-batched write to overflowQ. Should only be called by WorkerTransfer returns false if overflowLimit has reached

Release the slot occupied by this assignment.

Unregisters a callback function that was registered with register(...). @param id is the String id that was returned from register(...).

This interface is used by ShellBolt and ShellSpout through RPC call to update Metric. @param value used to update metric, its's meaning change ac

Update the state by applying the given state update function to the previous state of the key and the new value for the key. This internally uses {@li

Called to update the subject on the worker side when new credentials are received. This means that populateSubject has already been called on this sub

Convert the supplied user name to the actual user name that should be used in the system. This may be called on any name. If it cannot be translated