org.apache.flink.runtime.io.network.partition

Interface PartitionProducerStateProvider.ResponseHandle

Enclosing interface:

PartitionProducerStateProvider

public static interface PartitionProducerStateProvider.ResponseHandle

Result of state query, accepts state check callbacks.

Method Summary

Modifier and Type	Method and Description
void	cancelConsumption() Cancel the partition consumptions as a result of state check.
void	failConsumption(Throwable cause) Fail the partition consumptions as a result of state check.
ExecutionState	getConsumerExecutionState()
Either<ExecutionState,Throwable>	getProducerExecutionState()

Method Detail

getConsumerExecutionState

ExecutionState getConsumerExecutionState()

getProducerExecutionState

Either<ExecutionState,Throwable> getProducerExecutionState()

cancelConsumption

void cancelConsumption()

Cancel the partition consumptions as a result of state check.

failConsumption

void failConsumption(Throwable cause)

Fail the partition consumptions as a result of state check.

Parameters:

cause - failure cause