org.apache.flink.runtime.jobmaster

Interface LogicalSlot.Payload

All Known Implementing Classes:

Execution

Enclosing interface:

LogicalSlot

public static interface LogicalSlot.Payload

Payload for a logical slot.

Method Summary

Modifier and Type	Method and Description
void	fail(Throwable cause) Fail the payload with the given cause.
CompletableFuture<?>	getTerminalStateFuture() Gets the terminal state future which is completed once the payload has reached a terminal state.

Method Detail

fail

void fail(Throwable cause)

Fail the payload with the given cause.

Parameters:

cause - of the failure

getTerminalStateFuture

CompletableFuture<?> getTerminalStateFuture()

Gets the terminal state future which is completed once the payload has reached a terminal state.

Returns:

Terminal state future