org.apache.flink.streaming.runtime.tasks.mailbox

类 Mail

java.lang.Object

org.apache.flink.streaming.runtime.tasks.mailbox.Mail

@Internal
public class Mail
extends Object

An executable bound to a specific operator in the chain, such that it can be picked for downstream mailbox.

构造器概要

构造器

构造器和说明
Mail(org.apache.flink.api.common.operators.MailboxExecutor.MailOptions mailOptions, org.apache.flink.util.function.ThrowingRunnable<? extends Exception> runnable, int priority, StreamTaskActionExecutor actionExecutor, String descriptionFormat, Object... descriptionArgs)
Mail(org.apache.flink.util.function.ThrowingRunnable<? extends Exception> runnable, int priority, String descriptionFormat, Object... descriptionArgs)

方法概要

限定符和类型	方法和说明
org.apache.flink.api.common.operators.MailboxExecutor.MailOptions	getMailOptions()
int	getPriority()
void	run()
String	toString()
void	tryCancel(boolean mayInterruptIfRunning)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

构造器详细资料

Mail

public Mail(org.apache.flink.util.function.ThrowingRunnable<? extends Exception> runnable,
            int priority,
            String descriptionFormat,
            Object... descriptionArgs)

Mail

public Mail(org.apache.flink.api.common.operators.MailboxExecutor.MailOptions mailOptions,
            org.apache.flink.util.function.ThrowingRunnable<? extends Exception> runnable,
            int priority,
            StreamTaskActionExecutor actionExecutor,
            String descriptionFormat,
            Object... descriptionArgs)

方法详细资料

getMailOptions

public org.apache.flink.api.common.operators.MailboxExecutor.MailOptions getMailOptions()

getPriority

public int getPriority()

tryCancel

public void tryCancel(boolean mayInterruptIfRunning)

toString

public String toString()

覆盖:

toString 在类中 Object

run

public void run()
         throws Exception

抛出:

Exception