Package | Description |
---|---|
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.streaming.runtime.tasks.mailbox |
Modifier and Type | Class and Description |
---|---|
static class |
StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor
Deprecated.
this class should only be used in
SourceStreamTask which exposes the checkpoint lock as part of Public API.
During transitional period it is used in StreamTask (until StreamTask.getCheckpointLock()
is pushed down to SourceStreamTask ). |
Modifier and Type | Field and Description |
---|---|
static StreamTaskActionExecutor |
StreamTaskActionExecutor.IMMEDIATE |
Constructor and Description |
---|
Mail(RunnableWithException runnable,
int priority,
StreamTaskActionExecutor actionExecutor,
String descriptionFormat,
Object... descriptionArgs) |
MailboxExecutorImpl(TaskMailbox mailbox,
int priority,
StreamTaskActionExecutor actionExecutor) |
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction,
StreamTaskActionExecutor actionExecutor) |
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction,
StreamTaskActionExecutor actionExecutor,
TaskMailbox mailbox,
MailboxExecutor mainMailboxExecutor) |
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction,
TaskMailbox mailbox,
StreamTaskActionExecutor actionExecutor) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.