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 | Method and Description |
---|---|
protected void |
StreamTask.processInput(MailboxDefaultAction.Controller controller)
This method implements the default action of the task (e.g.
|
protected void |
StreamIterationHead.processInput(MailboxDefaultAction.Controller controller) |
protected void |
SourceStreamTask.processInput(MailboxDefaultAction.Controller controller) |
Modifier and Type | Class and Description |
---|---|
protected static class |
MailboxProcessor.MailboxController
Implementation of
MailboxDefaultAction.Controller that is connected to a MailboxProcessor instance. |
Modifier and Type | Method and Description |
---|---|
void |
MailboxDefaultAction.runDefaultAction(MailboxDefaultAction.Controller controller)
This method implements the default action of the mailbox loop (e.g.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.