Sets the target stream of this Tuple. @param stream The target stream @return This

Delete old log dirs for which the workers are no longer alive.

Run a command.

Run profiling command. @param user the user that the worker is running as @param workerId the id of the worker @param command the command to run @para

sanitizeTransferredStats. @param stats stats @return sanitizeTransferredStats

Respond to server's SASL token. @param saslTokenMessage contains server's SASL token @return client's response SASL token

Scale all of the components in the topology by a percentage (but keep the throughput the same). @param v the amount to scale them by. 1.0 is nothing,

Scale the throughput of the entire topology by a percentage. @param v the amount to scale it by 1.0 is nothing 0.5 cuts it in half and 2.0 doubles it.

Scans all metrics in the store and returns the ones matching the specified filtering options. @param filter options to filter by @param scanCallbac

Scans all metrics in the store and returns the ones matching the specified filtering options. Callback returns raw key/value data. @param filter o

Reschedule any topologies as needed. @param lesserPools pools that may be used to steal nodes from.

Try to schedule till successful or till limits (backtrack count or time) have been exceeded. @param orderedExecutors Executors sorted in the preferre

Test {@link StormTimer#scheduleRecurring(int, int, Runnable)} for scheduling order under multithreaded environment.

Search from a worker log file. @param fileName log file @param user username @param isDaemon whether the log file is regarding worker or daemon @para