org.apache.flink.runtime.jobmaster

Enum JobMasterServiceProcess.WaitingForLeadership

java.lang.Object

java.lang.Enum<JobMasterServiceProcess.WaitingForLeadership>

org.apache.flink.runtime.jobmaster.JobMasterServiceProcess.WaitingForLeadership

All Implemented Interfaces:

Serializable, AutoCloseable, Comparable<JobMasterServiceProcess.WaitingForLeadership>, JobMasterServiceProcess, AutoCloseableAsync

Enclosing interface:

JobMasterServiceProcess

public static enum JobMasterServiceProcess.WaitingForLeadership
extends Enum<JobMasterServiceProcess.WaitingForLeadership>
implements JobMasterServiceProcess

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.jobmaster.JobMasterServiceProcess

JobMasterServiceProcess.WaitingForLeadership

Enum Constant Summary

Enum Constants

Enum Constant and Description
INSTANCE

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
CompletableFuture<JobMasterGateway>	getJobMasterGatewayFuture() Future which is completed with the JobMasterGateway once the JobMasterService has been created.
CompletableFuture<String>	getLeaderAddressFuture() Future which is completed with the JobMasterService address once it is created.
UUID	getLeaderSessionId() The leader session id of this process.
CompletableFuture<JobManagerRunnerResult>	getResultFuture() Future which is completed with the result of job execution.
boolean	isInitializedAndRunning() True iff the JobMasterService has been initialized and is running.
static JobMasterServiceProcess.WaitingForLeadership	valueOf(String name) Returns the enum constant of this type with the specified name.
static JobMasterServiceProcess.WaitingForLeadership[]	values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.jobmaster.JobMasterServiceProcess

waitingForLeadership

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Enum Constant Detail

INSTANCE

public static final JobMasterServiceProcess.WaitingForLeadership INSTANCE

Method Detail

values

public static JobMasterServiceProcess.WaitingForLeadership[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (JobMasterServiceProcess.WaitingForLeadership c : JobMasterServiceProcess.WaitingForLeadership.values())
    System.out.println(c);

Returns:

an array containing the constants of this enum type, in the order they are declared

valueOf

public static JobMasterServiceProcess.WaitingForLeadership valueOf(String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum type has no constant with the specified name

NullPointerException - if the argument is null

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed

getLeaderSessionId

public UUID getLeaderSessionId()

Description copied from interface: JobMasterServiceProcess

The leader session id of this process.

Specified by:

getLeaderSessionId in interface JobMasterServiceProcess

isInitializedAndRunning

public boolean isInitializedAndRunning()

Description copied from interface: JobMasterServiceProcess

True iff the JobMasterService has been initialized and is running.

Specified by:

isInitializedAndRunning in interface JobMasterServiceProcess

getJobMasterGatewayFuture

public CompletableFuture<JobMasterGateway> getJobMasterGatewayFuture()

Description copied from interface: JobMasterServiceProcess

Future which is completed with the JobMasterGateway once the JobMasterService has been created. Upon closing of the process, this future is completed exceptionally if it is still uncompleted.

Specified by:

getJobMasterGatewayFuture in interface JobMasterServiceProcess

getResultFuture

public CompletableFuture<JobManagerRunnerResult> getResultFuture()

Description copied from interface: JobMasterServiceProcess

Future which is completed with the result of job execution. The job's result can be the JobManagerRunnerResult, JobNotFinishedException if the job was not finished or an Throwable if an unexpected failure occurs. Upon closing of the process, this future is completed exceptionally with JobNotFinishedException.

Specified by:

getResultFuture in interface JobMasterServiceProcess

getLeaderAddressFuture

public CompletableFuture<String> getLeaderAddressFuture()

Description copied from interface: JobMasterServiceProcess

Future which is completed with the JobMasterService address once it is created.

Specified by:

getLeaderAddressFuture in interface JobMasterServiceProcess