Package | Description |
---|---|
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.streaming.runtime.tasks.mailbox |
Class and Description |
---|
MailboxDefaultAction.Controller
This context is a feedback interface for the default action to interact with the mailbox execution.
|
MailboxExecutorFactory
A factory for creating mailbox executors with a given priority.
|
MailboxProcessor
This class encapsulates the logic of the mailbox-based execution model.
|
TaskMailbox
A task mailbox provides read and write access to a mailbox and has a lifecycle of open -> (quiesced) -> closed.
|
Class and Description |
---|
Mail
An executable bound to a specific operator in the chain, such that it can be picked for downstream mailbox.
|
MailboxDefaultAction
Interface for the default action that is repeatedly invoked in the mailbox-loop.
|
MailboxDefaultAction.Controller
This context is a feedback interface for the default action to interact with the mailbox execution.
|
MailboxDefaultAction.Suspension
Represents the suspended state of a
MailboxDefaultAction , ready to resume. |
TaskMailbox
A task mailbox provides read and write access to a mailbox and has a lifecycle of open -> (quiesced) -> closed.
|
TaskMailbox.State
This enum represents the states of the mailbox lifecycle.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.