Package | Description |
---|---|
org.apache.flink.api.connector.sink | |
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.state.changelog | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.async | |
org.apache.flink.streaming.runtime.io.checkpointing | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.streaming.runtime.tasks.mailbox |
Modifier and Type | Method and Description |
---|---|
MailboxExecutor |
Sink.InitContext.getMailboxExecutor()
Returns the mailbox executor that allows to execute
Runnable s inside the task
thread in between record processing. |
Modifier and Type | Method and Description |
---|---|
default MailboxExecutor |
Environment.getMainMailboxExecutor() |
Modifier and Type | Method and Description |
---|---|
default void |
Environment.setMainMailboxExecutor(MailboxExecutor mainMailboxExecutor) |
Modifier and Type | Method and Description |
---|---|
MailboxExecutor |
RuntimeEnvironment.getMainMailboxExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
RuntimeEnvironment.setMainMailboxExecutor(MailboxExecutor mainMailboxExecutor) |
Constructor and Description |
---|
ChangelogKeyedStateBackend(AbstractKeyedStateBackend<K> keyedStateBackend,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
StateChangelogWriter<ChangelogStateHandle> stateChangelogWriter,
Collection<ChangelogStateBackendHandle> initialState,
MailboxExecutor mainMailboxExecutor,
ExecutorService asyncOperationsThreadPool) |
Modifier and Type | Method and Description |
---|---|
protected MailboxExecutor |
AbstractStreamOperatorFactory.getMailboxExecutor()
Provides the mailbox executor iff this factory implements
YieldingOperatorFactory . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractStreamOperatorFactory.setMailboxExecutor(MailboxExecutor mailboxExecutor) |
void |
YieldingOperatorFactory.setMailboxExecutor(MailboxExecutor mailboxExecutor) |
Constructor and Description |
---|
AsyncWaitOperator(AsyncFunction<IN,OUT> asyncFunction,
long timeout,
int capacity,
AsyncDataStream.OutputMode outputMode,
ProcessingTimeService processingTimeService,
MailboxExecutor mailboxExecutor) |
Modifier and Type | Method and Description |
---|---|
static CheckpointBarrierHandler |
InputProcessorUtil.createCheckpointBarrierHandler(CheckpointableTask toNotifyOnCheckpoint,
StreamConfig config,
SubtaskCheckpointCoordinator checkpointCoordinator,
String taskName,
List<IndexedInputGate>[] inputGates,
List<StreamTaskSourceInput<?>> sourceInputs,
MailboxExecutor mailboxExecutor,
TimerService timerService) |
static CheckpointedInputGate[] |
InputProcessorUtil.createCheckpointedMultipleInputGate(MailboxExecutor mailboxExecutor,
List<IndexedInputGate>[] inputGates,
TaskIOMetricGroup taskIOMetricGroup,
CheckpointBarrierHandler barrierHandler,
StreamConfig config) |
Constructor and Description |
---|
CheckpointedInputGate(InputGate inputGate,
CheckpointBarrierHandler barrierHandler,
MailboxExecutor mailboxExecutor)
Creates a new checkpoint stream aligner.
|
CheckpointedInputGate(InputGate inputGate,
CheckpointBarrierHandler barrierHandler,
MailboxExecutor mailboxExecutor,
UpstreamRecoveryTracker upstreamRecoveryTracker) |
Modifier and Type | Method and Description |
---|---|
ProcessingTimeService |
ProcessingTimeServiceFactory.createProcessingTimeService(MailboxExecutor mailboxExecutor)
Creates a new processing time service with the mailbox executor.
|
Modifier and Type | Class and Description |
---|---|
class |
MailboxExecutorImpl
Implementation of an executor service build around a mailbox-based execution model.
|
Modifier and Type | Method and Description |
---|---|
MailboxExecutor |
MailboxExecutorFactory.createExecutor(int priority)
Creates a new executor for the given priority.
|
MailboxExecutor |
MailboxProcessor.getMailboxExecutor(int priority)
Returns an executor service facade to submit actions to the mailbox.
|
MailboxExecutor |
MailboxProcessor.getMainMailboxExecutor() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.