Set remote subject explicitly.

Writes this metadata object to a Map so Trident can read/write it to Zookeeper.

Add bind mount locations. @param sourcePath the source path @param destinationPath the destination path @param createSource if createSource is false a

Add another supervisor to the topology. This is intended mostly for internal testing.

Return a {@link ConcurrentMap} view of the current entries in the cache. @return the map of key-values currently cached.

Assigns a worker to a node. @param target the worker slot to assign the executors @param td the topology the executors are from @param exec

Assign partitions to the KafkaConsumer. @param consumer The Kafka consumer to assign partitions to @param newAssignment The partitions to assign. @par

Advanced search across worker log files in a topology. @param topologyId topology ID @param user username @param search search string @param numMatch

Dump a string to a file. @param location where to write to @param data the data to write @throws IOException on any error

Method to execute a shell command. Covers most of the simple cases without requiring the user to implement the {@link ShellUtils} interface. @param c

Check if a file exists or not. @param path the path to check @return true if it exists else false @throws IOException on any error.

free the slots. @param slots multiple slots to free

Get value from the cache or load the value. @param key the key @return the value

Get the Kafka TopicPartitions subscribed to by this set of spouts. @param consumer The Kafka consumer to use to read the list of existing partitions @

This function either returns the blobs in the existing cache or if they don't exist in the cache, it downloads them in parallel (up to SUPERVISOR_BLOB

Get a topology given an ID. @param topologyId the id of the topology to get @return the topology or null if it is not found

Returns descriptor which defines data type. @return data type descriptor

Return an object that maps component names to a numeric maximum limit of executor instances (of that component) that can exist on any node. The map

Returns password. @return password

Construct a principal to local plugin. @param topoConf storm configuration @return the plugin

Gets the Thrift object representing the topology. @return the Thrift definition representing the topology

InputStream to read the fully qualified resource path. @param resource path to read. @return InputStream of the resource being read.

Returns the sliding length of the moving window.

getTopologySummary. @param topologyPageInfo topologyPageInfo @param window window @param config config @param remoteUser remoteUser @return getTopolog

Returns the windowed parent streams. These are the streams where punctuations arrive. @return the windowed parent streams

Get the user of the worker. @return the user that some operations should be done as. @throws IOException on any error

Checks if a executor is part of this topology. @return Boolean whether or not a certain ExecutorDetail is included in the resourceList.

Decide if the caller currently has the leader lock. @return true if the caller currently has the leader lock.