Kill a process.

Launch the supervisor.

Localize the oci resource. @param ociResource the oci resource to be localized @return the destination of the localized resource. @throws IOException

Provides a worker log file to view, starting from the specified position or default starting position of the most recent page. @param fileName file t

Try to see if this looks like a trident topology. NOTE: this will not work for anonymized configs @return true if it does else false.

Factory to create the right container launcher for the config and the environment. @param conf the config @param supervisorId the ID of the supervisor

Constructs a TimeCacheMap instance with a blob store timeout whose expiration callback invokes cancel on the value held by an expired entry when that

Make test Topology configuration, but with the newer spread constraints that allow associating a number with the spread. This number represents the ma

Utility method for creating dependencies for TopologyInfo that include one spout component.

The maximum number of window events to keep in memory.

This aggregator operation computes the minimum of tuples by the given {@code inputFieldName} and it is assumed that its value is an instance of {@code

Create message. @param encoded status code @return a control message per an encoded status code

Create a new worker heartbeat for zookeeper. @param topoId the topology id @param executorStats the stats for the executors @param uptime the uptime f

Monitor the list of topologies for the given time frame. @param execTimeMins how long to monitor for @param client the client to use when monitoring @

Does the topology need scheduling. <p>A topology needs scheduling if one of the following conditions holds: <ul> <li>Although the topology is assign

Get the next action to perform based on this checkpoint state. @param recovering if in recovering phase @return the next action to perform based on t

Get the next key to emit. @return the key that should be emitted.