Class Hierarchy
- java.lang.Object
- org.apache.flink.runtime.clusterframework.messages.CheckAndAllocateContainers (implements java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.FatalErrorOccurred (implements java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.GetClusterStatus (implements java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse (implements java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.InfoMessage (implements java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.NewLeaderAvailable (implements java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.NotifyResourceStarted (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.ReconnectResourceManager (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.RegisterInfoMessageListener (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.RegisterInfoMessageListenerSuccessful (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.RegisterResourceManager (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.RegisterResourceManagerSuccessful (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.RemoveResource (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.ResourceRemoved (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.SetWorkerPoolSize (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.ShutdownClusterAfterJob (implements java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.StopCluster (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.StopClusterSuccessful (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.TriggerRegistrationAtJobManager (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
- org.apache.flink.runtime.clusterframework.messages.UnRegisterInfoMessageListener (implements org.apache.flink.runtime.messages.RequiresLeaderSessionID, java.io.Serializable)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.