org.apache.flink.yarn

Class YarnMessages

java.lang.Object

org.apache.flink.yarn.YarnMessages

public class YarnMessages
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	YarnMessages.AcknowledgeApplicationClientRegistration$ Response to a RegisterApplicationClient message which led to a successful registration of the ApplicationClient
static class	YarnMessages.ApplicationMasterStatus
static class	YarnMessages.ApplicationMasterStatus$
static class	YarnMessages.CheckForUserCommand$
static class	YarnMessages.HeartbeatWithYarn$
static class	YarnMessages.JobManagerLeaderAddress Notification message that a new leader has been found.
static class	YarnMessages.JobManagerLeaderAddress$
static class	YarnMessages.JobManagerStopped$
static class	YarnMessages.LocalGetYarnClusterStatus$
static class	YarnMessages.LocalGetYarnMessage$
static class	YarnMessages.LocalStopAMAfterJob
static class	YarnMessages.LocalStopAMAfterJob$
static class	YarnMessages.LocalStopYarnSession
static class	YarnMessages.LocalStopYarnSession$
static class	YarnMessages.PollYarnClusterStatus$
static class	YarnMessages.RegisterApplicationClient$ Registration message sent from the ApplicationClient to the YarnJobManager.
static class	YarnMessages.StartYarnSession Entry point to start a new YarnSession.
static class	YarnMessages.StartYarnSession$
static class	YarnMessages.StopAMAfterJob
static class	YarnMessages.StopAMAfterJob$
static class	YarnMessages.StopYarnSession
static class	YarnMessages.StopYarnSession$
static class	YarnMessages.TriggerApplicationClientRegistration Triggers the registration of the ApplicationClient to the YarnJobManager
static class	YarnMessages.TriggerApplicationClientRegistration$
static class	YarnMessages.UnregisterClient$
static class	YarnMessages.YarnContainersAllocated Callback from the async resource manager client when containers were allocated.
static class	YarnMessages.YarnContainersAllocated$
static class	YarnMessages.YarnContainersCompleted Callback from the async resource manager client when containers were completed.
static class	YarnMessages.YarnContainersCompleted$
static class	YarnMessages.YarnMessage
static class	YarnMessages.YarnMessage$

Constructor Summary

Constructors

Constructor and Description
YarnMessages()

Method Summary

Modifier and Type	Method and Description
static Object	getLocalGetyarnClusterStatus()
static Object	getLocalGetYarnMessage()

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnMessages

public YarnMessages()

Method Detail

getLocalGetYarnMessage

public static Object getLocalGetYarnMessage()

getLocalGetyarnClusterStatus

public static Object getLocalGetyarnClusterStatus()