Package | Description |
---|---|
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.async | |
org.apache.flink.streaming.runtime.tasks.mailbox |
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,
MailboxExecutor mailboxExecutor) |
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()
Returns a pre-created executor service that executes all mails.
|
Constructor and Description |
---|
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction,
StreamTaskActionExecutor actionExecutor,
TaskMailbox mailbox,
MailboxExecutor mainMailboxExecutor) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.