Like the equals command, but ignores the resources. @param other the object to check for equality against. @return true if they are equal, ignoring r

Decides if an event should be expired from the window, processed in the current window or kept for later processing. @param event the input event @re

Converts exception into json map. @param ex Exception to be converted. @param statusCode Status code to be returned. @return Map to be converted into

Returns the position of the specified named field. @param field Named field to evaluate @throws IllegalArgumentException - if field does not exist

Returns the position of the specified field in this tuple. @throws IllegalArgumentException - if field does not exist

filter system streams from stats. @param stream2stat { stream id -> value } @param includeSys whether to filter system streams @return filtered stat

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

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

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

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

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

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

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

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

Frees a single slot in this node. @param ws the slot to free

Parses a string (command line) representation of "<SLOWNESS>(:<COUNT>)?". @param strRepresentation the string representation to parse @ret

Gets the field at position index in the collection. @param index index of the field to return @throws IndexOutOfBoundsException - if the index is out

Return a set of all worker directories in all topology directories in root log directory.

Given a java.util.List of contructor/method arguments, and a list of parameter types, attempt to convert the list to an java.lang.Object array that ca

Get heap memory usage for a worker's main process and logwriter process. @param topConf - the topology config @return the assigned memory (in MB)

Get all of the configured AutoCredential Plugins. @param topoConf the storm configuration to use. @return the configured auto credentials.

The lookup key for the config key string. @return the config key string

Returns database index. @return database index

The port the DRPC invoke server is listening on. @return The port the DRPC invoke server is listening on.

The emitter for a TransactionalSpout runs as many tasks across the cluster. Emitters are responsible for emitting batches of tuples for a transaction

Get fields. @return an immutable list of any additional data fields of the object (may be empty but will never be null)

Returns list of groups for a user. @param user get groups for this user @return list of groups for a given user

a Unix command to get a given user's groups list. Windows is not supported.

Get the current load for the given tasks. @param tasks the tasks to look for. @return a Load for each of the tasks it knows about.

Returns limit of redirection. @return limit of redirection

Gets the {@link KafkaSpoutMessageId} for the record on the given topic partition and offset. @param topicPartition The topic partition of the record @

Get the metadata string portion of the value. Assumes the value is metadata. @return the metadata string