org.apache.flink.yarn

Class RegisterApplicationMasterResponseReflector$

java.lang.Object

org.apache.flink.yarn.RegisterApplicationMasterResponseReflector$

public class RegisterApplicationMasterResponseReflector$
extends Object

Singleton object to reflect the getContainersFromPreviousAttempts method for RegisterApplicationMasterResponse.

Only Hadoop versions (>= 2.4.0) support RegisterApplicationMasterResponse#getContainersFromPreviousAttempts. Therefore, it's checked at runtime whether the RegisterApplicationMasterResponse supports this method. If not, then an empty Seq[Container] is returned upon calling getContainersFromPreviousAttempts.

Field Summary

Fields

Modifier and Type	Field and Description
static RegisterApplicationMasterResponseReflector$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
RegisterApplicationMasterResponseReflector$()

Method Summary

Modifier and Type	Method and Description
scala.collection.Seq<org.apache.hadoop.yarn.api.records.Container>	getContainersFromPreviousAttempts(org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse response)
grizzled.slf4j.Logger	log()
scala.Option<Method>	methodOption()

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final RegisterApplicationMasterResponseReflector$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

RegisterApplicationMasterResponseReflector$

public RegisterApplicationMasterResponseReflector$()

Method Detail

log

public grizzled.slf4j.Logger log()

methodOption

public scala.Option<Method> methodOption()

getContainersFromPreviousAttempts

public scala.collection.Seq<org.apache.hadoop.yarn.api.records.Container> getContainersFromPreviousAttempts(org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse response)