org.apache.flink.streaming.runtime.tasks.mailbox

Interface MailboxDefaultAction.Controller

All Known Implementing Classes:

MailboxProcessor.MailboxController

Enclosing interface:

MailboxDefaultAction

@Internal
public static interface MailboxDefaultAction.Controller

This context is a feedback interface for the default action to interact with the mailbox execution. In particular it offers ways to signal that the execution of the default action should be finished or temporarily suspended.

Method Summary

Modifier and Type	Method and Description
void	allActionsCompleted() This method must be called to end the stream task when all actions for the tasks have been performed.
MailboxDefaultAction.Suspension	suspendDefaultAction() Calling this method signals that the mailbox-thread should (temporarily) stop invoking the default action, e.g.

Method Detail

allActionsCompleted

void allActionsCompleted()

This method must be called to end the stream task when all actions for the tasks have been performed. This method can be invoked from any thread.

suspendDefaultAction

MailboxDefaultAction.Suspension suspendDefaultAction()

Calling this method signals that the mailbox-thread should (temporarily) stop invoking the default action, e.g. because there is currently no input available. This method must be invoked from the mailbox-thread only!