Package | Description |
---|---|
org.apache.flink.streaming.runtime.tasks.mailbox |
Modifier and Type | Method and Description |
---|---|
Mail |
TaskMailboxImpl.take(int priority) |
Mail |
TaskMailbox.take(int priority)
This method returns the oldest mail from the mailbox (head of queue) or blocks until a mail
is available.
|
Modifier and Type | Method and Description |
---|---|
List<Mail> |
TaskMailboxImpl.close() |
List<Mail> |
TaskMailbox.close()
Close the mailbox.
|
List<Mail> |
TaskMailboxImpl.drain() |
List<Mail> |
TaskMailbox.drain()
Drains the mailbox and returns all mails that were still enqueued.
|
Optional<Mail> |
TaskMailboxImpl.tryTake(int priority) |
Optional<Mail> |
TaskMailbox.tryTake(int priority)
Returns an optional with either the oldest mail from the mailbox (head of queue) if the
mailbox is not empty or an empty optional otherwise.
|
Optional<Mail> |
TaskMailboxImpl.tryTakeFromBatch() |
Optional<Mail> |
TaskMailbox.tryTakeFromBatch()
Returns an optional with either the oldest mail from the batch (head of queue) if the batch
is not empty or an empty optional otherwise.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskMailboxImpl.put(Mail mail) |
void |
TaskMailbox.put(Mail mail)
Enqueues the given mail to the mailbox and blocks until there is capacity for a successful
put.
|
void |
TaskMailboxImpl.putFirst(Mail mail) |
void |
TaskMailbox.putFirst(Mail mail)
Adds the given action to the head of the mailbox.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.