Get a topology ID from the name of a topology. @param topologyName the name of the topology to look for @return the id of the topology or null if it

The primary principal associated current subject.

Called when a spout has been activated out of a deactivated mode. nextTuple will be called on this spout soon. A spout can become activated after havi

Check if a Metric matches another object.

Borrows instance from container. @return instance which implements RedisCommands

This method would be invoked when the {@link EventLoggerBolt} receives a tuple from the spouts or bolts that has event logging enabled. @param e the

Set the amount of on heap memory for this component. @param onHeap the amount of on heap memory @return this for chaining

Submits a topology to run on the cluster with a progress bar. A topology runs forever or until explicitly killed. @param name the name of the sto

Get the assignment based on storm id from local backend. @param stormId topology id @param callback callback function @return {@link Assignment}

Get context. @return a request context associated with current thread

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

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

Add an option to be parsed. @param shortName the short single character name of the option (no `-` character proceeds it). @param longName the multi c

Run what you need with the nimbus client. @param client the client. @throws Exception on any error.

Add command commandWithArguments. This method is only meant for use by sub-classes. @param arguments to be added

The event timestamp in millis. This could be the time when the source generated the tuple or the time when the tuple was received by a bolt. @return

Set the number of supervisors the cluster should have.

Deletes a file or directory and its contents if it exists. Does not complain if the input is null or does not exist. @param path the path to the file

Submits a topology to run on the cluster. A topology runs forever or until explicitly killed. @param name the name of the storm. @param topoConf

called once when the system is shutting down, should be idempotent.

Get the map of executor to WorkerSlot. @return the executor -> slot map.

Return the ID of the topology. @return the topology-id this assignment is for.

Execute a sequence of calls on HdfsSpout. @param cmds: set of commands to run, e.g. "r,r,r,r,a1,f2,...". The commands are: r[N] - receive() called N

Given a tuple, return the value that should be written to the sequence file.

Delete a file or a directory and all of the children. If it exists. @param path what to delete @param user who to delete it as if doing it

Find a the enum type by its integer value, as defined in the Thrift IDL. @return null if the value is not found.

Gets the task ids allocated for the given component id. The task ids are always returned in ascending order.

Get storm runtime id from local. @param stormName name of a storm @return runtime storm id

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

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

Forwards the input to all downstream processors. @param input the input

Gets the Long field with a specific name. @throws ClassCastException If that field is not a Long @throws IllegalArgumentException - if field do

Returns the second value in a pair. @return the second value

Gets the id of the component that created this tuple.

Convert the input into a list of string; ignore null members. @param o the input object @return a list of string

Load scheduler configs associated with the configKey. @param configKey The key from which we want to get the scheduler config. @return The scheduler c

Schedule a function to run recurrently. @param delaySecs the number of seconds to delay before running the function @param recurSecs the time between

Commit a previously prepared transaction. It should be possible to retrieve a committed state later. @param txid the transaction id