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

Class DirectTimelineWriter

java.lang.Object

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

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

All Implemented Interfaces:

Flushable

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public class DirectTimelineWriter
extends TimelineWriter

A simple writer class for storing Timeline data into Leveldb store.

Constructor Summary

Constructors

Constructor and Description
DirectTimelineWriter(org.apache.hadoop.security.UserGroupInformation authUgi, com.sun.jersey.api.client.Client client, URI resURI)

Method Summary

Modifier and Type	Method and Description
void	putDomain(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, org.apache.hadoop.yarn.api.records.timeline.TimelineDomain domain)
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)

Methods inherited from class org.apache.hadoop.yarn.client.api.impl.TimelineWriter

close, doPostingObject, flush, putDomain, putEntities, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectTimelineWriter

public DirectTimelineWriter(org.apache.hadoop.security.UserGroupInformation authUgi,
                            com.sun.jersey.api.client.Client client,
                            URI resURI)

Method Detail

putEntities

public 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

Specified by:

putEntities in class TimelineWriter

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

putDomain

public 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

Specified by:

putDomain in class TimelineWriter

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException