Package | Description |
---|---|
org.apache.flink.streaming.runtime.tasks.mailbox |
Modifier and Type | Method and Description |
---|---|
MailboxMetricsController |
MailboxProcessor.getMailboxMetricsControl()
Gets
MailboxMetricsController for control and access to mailbox metrics. |
Constructor and Description |
---|
MailboxProcessor(MailboxDefaultAction mailboxDefaultAction,
TaskMailbox mailbox,
StreamTaskActionExecutor actionExecutor,
MailboxMetricsController mailboxMetricsControl) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.