getComponentErrors. @param errorInfoList errorInfoList @param topologyId topologyId @param config config @return getComponentErrors

getComponentLastErrorInfo. Internal helper method that populates a hashmap with the component's most recently reported error. If the component has no

Gets the set of streams declared for the specified component.

Get a map of version to classpath from the conf Config.SUPERVISOR_WORKER_VERSION_CLASSPATH_MAP @param conf what to read it out of @param current

Get a supervisor client as configured by conf. @param conf the configuration to use. @param host the host to use. @param port the port to use. @param

Get a nimbus client as configured by conf. @param conf the configuration to use. @param asUser the user to impersonate (this does not always work). @r

Returns the current context that is part of this eviction policy. @return the eviction context

Returns the current count of events in the queue up to the reference time based on which count based evictions can be performed. @return the current

Return a sorted set of paths that were written by workers that are now dead.

Get the log lines that contain the unique {@link StringDecorator} string, deserialized from json. The intent is that test bolts or spouts can write th

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

Get configurations for a section. @param configuration The config to pull the key/value pairs out of. @param section The app configuration entr

return an array containing the command name & its parameters.

filter ExecutorSummary whose stats is null. @param summs a list of ExecutorSummary @return filtered summs

Get host -> rack map - the inverse of networkTopography.

The port the HTTP server is listening on. Not available until {@link #start() } has run. @return The port the HTTP server is listening on. Not availab

Get image name from topology Conf. @param topoConf topology configuration @return the image name

Borrows Jedis instance from pool. <p/> Note that you should return borrowed instance to pool when you finish using instance. @return Jedis instance

Borrows JedisCluster instance. <p>Note that you should return borrowed instance when you finish using instance. @return JedisCluster instance

Returns KeyFactory which is used for converting state key -> Redis key. @return key factory

The maximum time lag of the tuple timestamp in milliseconds. It means that the tuple timestamps cannot be out of order by more than this amount. @ret

returns the last log entry.

checks if lockFile is older than 'olderThan' UTC time by examining the modification time on file and (if necessary) the timestamp in last log entry in

Get the time of the last login. @return the number of milliseconds since the beginning of time.

The name of the stream where late arriving tuples should be emitted. If this is not provided, the late tuples would be discarded. @return the name of