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. |
Modifier and Type | Field and Description |
---|---|
static StreamTaskActionExecutor |
StreamTaskActionExecutor.IMMEDIATE |
Modifier and Type | Method and Description |
---|---|
void |
StreamOperatorWrapper.close(StreamTaskActionExecutor actionExecutor,
boolean isStoppingBySyncSavepoint)
Closes the wrapped operator and propagates the close operation to the next wrapper that the
StreamOperatorWrapper.next points to. |
protected void |
OperatorChain.closeOperators(StreamTaskActionExecutor actionExecutor)
Closes all operators in a chain effect way.
|
Constructor and Description |
---|
StreamTask(Environment environment,
TimerService timerService,
Thread.UncaughtExceptionHandler uncaughtExceptionHandler,
StreamTaskActionExecutor actionExecutor)
Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
|
StreamTask(Environment environment,
TimerService timerService,
Thread.UncaughtExceptionHandler uncaughtExceptionHandler,
StreamTaskActionExecutor actionExecutor,
TaskMailbox mailbox) |
Constructor and Description |
---|
Mail(ThrowingRunnable<? extends Exception> runnable,
int priority,
StreamTaskActionExecutor actionExecutor,
String descriptionFormat,
Object... descriptionArgs) |
MailboxExecutorImpl(TaskMailbox mailbox,
int priority,
StreamTaskActionExecutor actionExecutor) |
MailboxExecutorImpl(TaskMailbox mailbox,
int priority,
StreamTaskActionExecutor actionExecutor,
MailboxProcessor mailboxProcessor) |
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction,
StreamTaskActionExecutor actionExecutor) |
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction,
TaskMailbox mailbox,
StreamTaskActionExecutor actionExecutor) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.