Class MailOptionsImpl
- java.lang.Object
-
- org.apache.flink.api.common.operators.MailOptionsImpl
-
- All Implemented Interfaces:
MailboxExecutor.MailOptions
@Internal public class MailOptionsImpl extends Object implements MailboxExecutor.MailOptions
Options to configure behaviour of executing mailbox mails.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanisDeferrable()Runtime can decide to defer execution of deferrable mails.booleanisUrgent()The urgent mail will be executed first compared to other mails.
-
-
-
Method Detail
-
isDeferrable
public boolean isDeferrable()
Description copied from interface:MailboxExecutor.MailOptionsRuntime can decide to defer execution of deferrable mails. For example, to unblock subtask thread as quickly as possible, deferrable mails are not executed duringMailboxExecutor.yield()orMailboxExecutor.tryYield(). This is done to speed up checkpointing, by skipping execution of potentially long-running mails.- Specified by:
isDeferrablein interfaceMailboxExecutor.MailOptions
-
isUrgent
public boolean isUrgent()
Description copied from interface:MailboxExecutor.MailOptionsThe urgent mail will be executed first compared to other mails. For example, handling unaligned checkpoint barrier or some control mails are expected to be executed as soon as possible.- Specified by:
isUrgentin interfaceMailboxExecutor.MailOptions
-
-