Uses of Class
org.apache.flink.runtime.operators.sort.StageRunner.SortStage

Packages that use StageRunner.SortStage

Package	Description
org.apache.flink.runtime.operators.sort

Uses of StageRunner.SortStage in org.apache.flink.runtime.operators.sort

Methods in org.apache.flink.runtime.operators.sort that return StageRunner.SortStage

Modifier and Type	Method	Description
static StageRunner.SortStage	StageRunner.SortStage.valueOf(String name)	Returns the enum constant of this type with the specified name.
static StageRunner.SortStage[]	StageRunner.SortStage.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.flink.runtime.operators.sort with parameters of type StageRunner.SortStage

Modifier and Type	Method	Description
org.apache.flink.runtime.operators.sort.CircularElement<E>	StageRunner.StageMessageDispatcher.poll(StageRunner.SortStage stage)	Retrieves and removes the head of the given stage queue, or returns null if the queue is empty.
void	StageRunner.StageMessageDispatcher.send(StageRunner.SortStage stage, org.apache.flink.runtime.operators.sort.CircularElement<E> element)	Sends a message to the given stage.
org.apache.flink.runtime.operators.sort.CircularElement<E>	StageRunner.StageMessageDispatcher.take(StageRunner.SortStage stage)	Retrieves and removes the head of the given queue, waiting if necessary until an element becomes available.