Find RASNode for specified node id. @param id the node/supervisor id to lookup @return a RASNode object

This method sets the input and output streams of the serializer. @param processIn output stream to non-JVM component @param processOut input stream

Find if the process is alive using the existence of /proc/<pid> directory owned by the supplied user. This is an alternative to "ps -p pid -u ui

Is the local override set or not. @return true of new clients will be overridden to connect to a local cluster and not the configured remote cluster.

Flag to indicate if the Pacameker is backend store. @return true if Pacemaker is being used as StateStore

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

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

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

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

Construct a Jetty Server instance.

Launch a new process as per {@link ProcessBuilder} with a given callback. @param command the command to be executed in the new process @para

Enumerate dump (profile) files for given worker. @param topologyId topology ID @param hostPort host and port of worker @param user username @return T

list files sorted by modification time that have not been modified since 'olderThan'. if 'olderThan' is <= 0 then the filtering is disabled

Returns an iterator with all the list of keys currently available on the blob store. @return {@code Iterator<String>}

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

Login if a HDFS keytab/principal have been supplied; otherwise, assume it's already logged in or running on insecure HDFS. This also guarantees that l

makeResponse. @param ex ex @param request request @param statusCode statusCode @return error response

Returns a new NestableFieldValidator for a Map of key to val. @param key the Class of keys in the map @param val the Class of values in the m

Get ZK ACLs for a topology to have read only access. @param topoConf the topology config. @return the ACLs.

Count how many times each element appears in the Collection. @param c a collection of values @return a map of the unique values in c to the count of t

populate metric values from the raw data.

Using the given KafkaUnit instance, put some messages in the specified topic. @param kafkaUnit The KafkaUnit instance to use @param topicName The top

This is a hook for the component to perform some actions just before the framework prepares its state.

Called when starting up. @param conf the cluster config @throws IOException on any error.

method must be idempotent.

Prettify uptime string. @param val val. @param dividers dividers. @return prettified uptime string.

Emit a batch of tuples for a partition/transaction that has been emitted before, using the metadata created when it was first emitted.

return null if file not found

Refresh the config only after the cache expires. This is not thread-safe and should only be called in single thread.

This method is called when this task is responsible for a new set of partitions. Should be used to manage things like connections to brokers. @param

Remove the other resources from this. This is the same as subtracting the resources in other from this. @param other the resources we want removed. @

Renew any credentials that need to be renewed. (Update the credentials if needed) @param credentials the credentials that may have somethi