Uses of Interface
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox

Packages that use TaskMailbox

Package	Description
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.runtime.tasks.mailbox

Uses of TaskMailbox in org.apache.flink.streaming.runtime.tasks

Constructors in org.apache.flink.streaming.runtime.tasks with parameters of type TaskMailbox

Constructor and Description
StreamTask(Environment environment, TimerService timerService, Thread.UncaughtExceptionHandler uncaughtExceptionHandler, StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor actionExecutor, TaskMailbox mailbox)

Uses of TaskMailbox in org.apache.flink.streaming.runtime.tasks.mailbox

Classes in org.apache.flink.streaming.runtime.tasks.mailbox that implement TaskMailbox

Modifier and Type	Class and Description
class	TaskMailboxImpl Implementation of TaskMailbox in a BlockingQueue fashion and tailored towards our use case with multiple writers and single reader.

Constructors in org.apache.flink.streaming.runtime.tasks.mailbox with parameters of type TaskMailbox

Constructor and Description
MailboxExecutorImpl(TaskMailbox mailbox, int priority, StreamTaskActionExecutor actionExecutor)
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction, StreamTaskActionExecutor actionExecutor, TaskMailbox mailbox, MailboxExecutor mainMailboxExecutor)
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction, TaskMailbox mailbox, StreamTaskActionExecutor actionExecutor)