Modifier and Type | Method and Description |
---|---|
MailboxExecutor |
Sink.InitContext.getMailboxExecutor()
Deprecated.
Returns the mailbox executor that allows to execute
Runnable s inside the task
thread in between record processing. |
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 |
---|---|
org.apache.flink.changelog.fs.FsStateChangelogWriter |
FsStateChangelogStorage.createWriter(String operatorID,
KeyGroupRange keyGroupRange,
MailboxExecutor mailboxExecutor) |
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 |
---|---|
StateChangelogWriter<Handle> |
StateChangelogStorage.createWriter(String operatorID,
KeyGroupRange keyGroupRange,
MailboxExecutor mailboxExecutor) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogWriter |
InMemoryStateChangelogStorage.createWriter(String operatorID,
KeyGroupRange keyGroupRange,
MailboxExecutor mailboxExecutor) |
Modifier and Type | Method and Description |
---|---|
MailboxExecutor |
RuntimeEnvironment.getMainMailboxExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
RuntimeEnvironment.setMainMailboxExecutor(MailboxExecutor mainMailboxExecutor) |
Constructor and Description |
---|
PeriodicMaterializationManager(MailboxExecutor mailboxExecutor,
ExecutorService asyncOperationsThreadPool,
String subtaskName,
AsyncExceptionHandler asyncExceptionHandler,
PeriodicMaterializationManager.MaterializationTarget target,
ChangelogMaterializationMetricGroup metricGroup,
long periodicMaterializeDelay,
int allowedNumberOfFailures,
String operatorSubtaskId) |
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 |
YieldingOperatorFactory.setMailboxExecutor(MailboxExecutor mailboxExecutor) |
void |
AbstractStreamOperatorFactory.setMailboxExecutor(MailboxExecutor mailboxExecutor) |
Constructor and Description |
---|
AsyncWaitOperator(AsyncFunction<IN,OUT> asyncFunction,
long timeout,
int capacity,
AsyncDataStream.OutputMode outputMode,
AsyncRetryStrategy<OUT> asyncRetryStrategy,
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) |
static BarrierAlignmentUtil.DelayableTimer |
BarrierAlignmentUtil.createRegisterTimerCallback(MailboxExecutor mailboxExecutor,
TimerService timerService) |
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() |
Modifier and Type | Method and Description |
---|---|
void |
MailboxMetricsController.setupLatencyMeasurement(TimerService timerService,
MailboxExecutor mailboxExecutor)
Sets up latency measurement with required
TimerService and MailboxExecutor . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.