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

Interface MailboxExecutorFactory

  • Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    @FunctionalInterface
@Internal
public interface MailboxExecutorFactory
    A factory for creating mailbox executors with a given priority. The factory is usually bound to a specific task.

    • Method Detail

      • createExecutor

        MailboxExecutor createExecutor​(int priority)
        Creates a new executor for the given priority. The priority is used when enqueuing new mails as well as yielding.
        Parameters:
        priority - the priority of the mailbox executor.
        Returns:
        a mailbox executor with the bound priority.