Skip <i>len</i> number of bytes in input stream<i>in</i>. @param in input stream @param len number of bytes to skip @throws IOException when skipped l

Sleep for a set number of nano seconds. @param start the start time of the sleep @param sleepAmount how many nano seconds after start when we should s

Read the contents of a file into a byte array. @param location the file to read @return the contents of the file @throws IOException on any error

Read the contents of a file into a String. @param location the file to read @return the contents of the file @throws IOException on any error

Used to sort a Map by the values - higher values up front.

sort components by the number of in and out connections that need to be made, in descending order. @param componentMap The components that need to be

Nodes are sorted by two criteria. <p>1) the number executors of the topology that needs to be scheduled is already on the node in descending order. T

Sort a component's neighbors by the number of connections it needs to make with this component. @param thisComp the component that we need to sor

Nodes are sorted by two criteria. <p>1) the number executors of the topology that needs to be scheduled is already on the node in descending order. T

Nodes are sorted by two criteria. <p>1) the number executors of the topology that needs to be scheduled is already on the node in descending order. T

Sort objects by the following three criteria. <li> The number executors of the topology that needs to be scheduled is already on the object (node

Sort objects by the following three criteria. <li> The number executors of the topology that needs to be scheduled is already on the object (node

Sort objects by the following two criteria. <li>the number executors of the topology that needs to be scheduled is already on the object (node or rac

Sort objects by the following two criteria. <li>the number executors of the topology that needs to be scheduled is already on the object (node or rac

Sort objects by the following two criteria. <li>the number executors of the topology that needs to be scheduled is already on the object (node or rac

Sort objects by the following two criteria. <li>the number executors of the topology that needs to be scheduled is already on the object (node or rac

aggregates spout stream stats, returns a Map of {metric -> win -> aggregated value}.

Start the trigger policy and waterMarkEventGenerator if set.

Submit jar file. @param conf the topology-specific configuration. See {@link Config}. @param localJar file path of the jar file to submit @return

Check if worker tokens are supported by this thrift server. @return true if they are else false.

Take unscheduled executors from current and all its downstream components in a particular order. First, take one executor from the current component;

Take nodes from this pool that can fulfill possibly up to the slotsNeeded. @param slotsNeeded the number of slots that are needed. @return a Collectio

Test max throughput with the specific config args.