Package org.apache.hadoop.yarn.api.records

Class CollectorInfo

java.lang.Object

org.apache.hadoop.yarn.api.records.CollectorInfo

@Public
@Evolving
public abstract class CollectorInfo
extends Object

Collector info containing collector address and collector token passed from RM to AM in Allocate Response.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final long	DEFAULT_TIMESTAMP_VALUE

Constructor Summary

Constructors

Constructor	Description
CollectorInfo()

Method Summary

Modifier and Type	Method	Description
abstract String	getCollectorAddr()
abstract Token	getCollectorToken()	Get delegation token for app collector which AM will use to publish entities.
static CollectorInfo	newInstance(String collectorAddr)
static CollectorInfo	newInstance(String collectorAddr, Token token)
abstract void	setCollectorAddr(String addr)
abstract void	setCollectorToken(Token token)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_TIMESTAMP_VALUE

protected static final long DEFAULT_TIMESTAMP_VALUE

See Also:

• Constant Field Values

Constructor Details

CollectorInfo

public CollectorInfo()

Method Details

newInstance

public static CollectorInfo newInstance(String collectorAddr)

newInstance

public static CollectorInfo newInstance(String collectorAddr,
 Token token)

getCollectorAddr

public abstract String getCollectorAddr()

setCollectorAddr

public abstract void setCollectorAddr(String addr)

getCollectorToken

public abstract Token getCollectorToken()

Get delegation token for app collector which AM will use to publish entities.

Returns:

the delegation token for app collector.

setCollectorToken

public abstract void setCollectorToken(Token token)