Package | Description |
---|---|
org.apache.flink.streaming.api.functions.source | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.async | |
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 |
---|---|
void |
ContinuousFileReaderOperatorFactory.setMailboxExecutor(MailboxExecutor mailboxExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
YieldingOperatorFactory.setMailboxExecutor(MailboxExecutor mailboxExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncWaitOperatorFactory.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 |
---|---|
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–2021 The Apache Software Foundation. All rights reserved.