Package org.apache.hadoop.yarn.client.api.impl

Class TimelineWriter

java.lang.Object

org.apache.hadoop.yarn.client.api.impl.TimelineWriter

All Implemented Interfaces:

Flushable

Direct Known Subclasses:

DirectTimelineWriter, FileSystemTimelineWriter

@Private
@Unstable
public abstract class TimelineWriter
extends Object
implements Flushable

Base writer class to write the Timeline data.

Constructor Summary

Constructors

Constructor	Description
TimelineWriter(org.apache.hadoop.security.UserGroupInformation authUgi, javax.ws.rs.client.Client client, URI resURI, net.jodah.failsafe.RetryPolicy<Object> retryPolicy)

Method Summary

Modifier and Type	Method	Description
void	close()
javax.ws.rs.core.Response	doPostingObject(Object object, String path)
void	flush()
abstract void	putDomain(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.timeline.TimelineDomain domain)
void	putDomain(org.apache.hadoop.yarn.api.records.timeline.TimelineDomain domain)
abstract org.apache.hadoop.yarn.api.records.timeline.TimelinePutResponse	putEntities(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.timeline.TimelineEntityGroupId groupId, org.apache.hadoop.yarn.api.records.timeline.TimelineEntity... entities)
org.apache.hadoop.yarn.api.records.timeline.TimelinePutResponse	putEntities(org.apache.hadoop.yarn.api.records.timeline.TimelineEntity... entities)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TimelineWriter

public TimelineWriter(org.apache.hadoop.security.UserGroupInformation authUgi,
 javax.ws.rs.client.Client client,
 URI resURI,
 net.jodah.failsafe.RetryPolicy<Object> retryPolicy)

Method Details

close

public void close()
           throws Exception

Throws:

Exception

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

putEntities

public org.apache.hadoop.yarn.api.records.timeline.TimelinePutResponse putEntities(org.apache.hadoop.yarn.api.records.timeline.TimelineEntity... entities)
                                                                            throws IOException,
org.apache.hadoop.yarn.exceptions.YarnException

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

putDomain

public void putDomain(org.apache.hadoop.yarn.api.records.timeline.TimelineDomain domain)
               throws IOException,
org.apache.hadoop.yarn.exceptions.YarnException

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

putEntities

public abstract org.apache.hadoop.yarn.api.records.timeline.TimelinePutResponse putEntities(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
 org.apache.hadoop.yarn.api.records.timeline.TimelineEntityGroupId groupId,
 org.apache.hadoop.yarn.api.records.timeline.TimelineEntity... entities)
                                                                                     throws IOException,
org.apache.hadoop.yarn.exceptions.YarnException

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

putDomain

public abstract void putDomain(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
 org.apache.hadoop.yarn.api.records.timeline.TimelineDomain domain)
                        throws IOException,
org.apache.hadoop.yarn.exceptions.YarnException

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

doPostingObject

@Private
@VisibleForTesting
public javax.ws.rs.core.Response doPostingObject(Object object,
 String path)
                                          throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException