Maps the value with the key. @param key the key @param value the value

Returns the wrapped object, E.g. a tuple @return the wrapped object.

Returns the number of fields in this tuple.

Add the string metadata to the cache. <p>NOTE: this can cause data to be evicted from the cache when full. When this occurs, the evictionCallback()

Get the string metadata from the cache. @param s The string to look for @return the metadata associated with the string or null if not found

Serialize this object to ByteBuf. @param dest The ByteBuf to serialize to

Gets the field at position i in the tuple. Returns object since tuples are dynamically typed. @throws IndexOutOfBoundsException - if the index is out

Read a String as a Network Int n, followed by n Bytes Alternative to 16 bit read/writeUTF. Encoding standard is... ?

Enable/disable logging the tuples generated in topology via an internal EventLogger bolt. The component name is optional and if null or empty, the deb

Returns the filename the HdfsBolt will create. @param rotation the current file rotation number (incremented on every rotation) @param timeStamp curre

Write a String as a Network Int n, followed by n Bytes Alternative to 16 bit read/writeUTF. Encoding standard is... ?

Get the map of the cache contents. Provided to allow writing the data to RocksDB on shutdown. @return the string metadata map entrySet

A static factory to create a {@link StateUpdater} based on an initial value of the state and a state update function. @param initialValue the intial

Get the key for this blob.

permit() method is invoked for each incoming Thrift request. @param context request context includes info about @param operation operation name @pa

Called when an ISpout is going to be shutdown. There is no guarentee that close will be called, because the supervisor kill -9's worker processes on t

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

Define a new bolt in this topology with parallelism of just one thread. @param id the id of this component. This id is referenced by other componen

Returns true if this tuple contains the specified name of the field.

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

Get the next tuple from the file. @return null if no more data

Tuples are randomly distributed across the bolt's tasks in a way such that each bolt is guaranteed to get an equal number of tuples.

The bolt component id. This is auto generated value like (bolt-N). @return the bolt id.

Build the cache. @param loader the {@link CacheLoader} @return the {@link WindowPartitionCache}

Returns the value mapped to the key. @param key the key @return the value or null if no mapping is found

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

Determines if a string Id is contained in the cache. @param stringId The string Id to check @return true if the Id is in the cache, false otherwise

Called for every tuple the HdfsBolt executes. @param tuple The tuple executed. @param offset current offset for the file being written @return true i

Storm has determined that the tuple emitted by this spout with the msgId identifier has been fully processed. Typically, an implementation of this met

Returns a stream consisting of the result of applying the given mapping function to the values of this stream. @param function a mapping function to

Define a new spout in this topology. @param id the id of this component. This id is referenced by other components that want to consume this spout

Get a sub-map by a given key. @param map the original map @param key the key to get it from @return the map stored under key

The tuple emitted by this spout with the msgId identifier has failed to be fully processed. Typically, an implementation of this method will put that

Uses default stream id.

Set all resources to 0.

Creates a window store. @param topoConf storm topology configuration passed in {@link org.apache.storm.trident.planner.TridentProcessor#prepare(Map,

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

Set assignments for the topologies which needs scheduling. The new assignments is available through `cluster.getAssignments()` @param topologies all

Performs an action for each element of this stream. @param action an action to perform on the elements

Converts state key to Redis key. @param key state key @return Redis key

Advance the cluster time when the cluster is using SimulatedTime. This is intended for internal testing only. @param secs the number of seconds to ad

Resolves a list of DNS-names/IP-address and returns back a map of DNS-name->switch information ( network paths). Consider an element in the argument l

When this method is called, Storm is requesting that the Spout emit tuples to the output collector. This method should be non-blocking, so if the Spou

The process finished. @param exitCode the exit code of the finished process.

Constructs a new pair of values. @param first the first value @param second the second value @param <T1> the type of the first value @param <T2>

This aggregator operation computes the maximum of tuples in a stream by using the given {@code comparator} with {@code TridentTuple}s. @param compara