Delete the oldest files in overloaded worker-artifacts globally.

Get a list of all topologyIds that currently have private worker keys stored, of any kind. This is expected to only ever be called from nimbus. @retu

Impair the cluster for a specified rackId. <li>making the host list a zero length</li> <li>removing supervisors for the hosts on the rack</li> @par

Impair the cluster for a specified rackId. <li>making the host list a zero length</li> <li>removing supervisors for the hosts on the rack</li> @par

Are any of the processes alive and running for the specified user. @param pids the PIDs of the running processes @param user the user that is expecte

Find if any of the Windows processes are alive and owned by the specified user. Command reference https://docs.microsoft.com/en-us/windows-server/admi

Decide if the assignments is synchronized. @return true if assignments have been synchronized from remote state store

Check if the assignment of the executor to the worker is valid. In simple cases, this is simply a check of {@link RasNode#wouldFit(WorkerSlot, Executo

Check if the current executor has a different component from the previous one. This flag can be used as a quick way to check if the nodes should be so

Should impersonation be allowed by this password provider. The default is false. @return true if it should else false.

Determines if a tuple should be filtered out of a stream. @param tuple the tuple being evaluated @return `false` to drop the tuple, `true` to keep th

tests if rhs == currOffset+1.

Is a process alive and running?. @param pid the PID of the running process @param user the user that is expected to own that process @return true if

Check if the scheduler is resource aware or not. @param conf The configuration @return True if it's resource aware; false otherwise

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

NOTE: this can return false when a topology has just been activated. The topology may still be in the STORMS_SUBTREE.