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

Class TimelineReaderClientImpl

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.service.CompositeService

org.apache.hadoop.yarn.client.api.TimelineReaderClient

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

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class TimelineReaderClientImpl
extends TimelineReaderClient

Implementation of TimelineReaderClient interface.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.service.CompositeService

org.apache.hadoop.service.CompositeService.CompositeServiceShutdownHook

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Field Summary

Fields inherited from class org.apache.hadoop.service.CompositeService

STOP_ONLY_STARTED_SERVICES

Constructor Summary

Constructors

Constructor and Description
TimelineReaderClientImpl()

Method Summary

Modifier and Type	Method and Description
protected com.sun.jersey.api.client.ClientResponse	doGetUri(URI base, String path, javax.ws.rs.core.MultivaluedMap<String,String> params)
protected String	encodeValue(String value)
List<org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity>	getApplicationAttemptEntities(org.apache.hadoop.yarn.api.records.ApplicationId appId, String fields, Map<String,String> filters, long limit, String fromId) Gets application attempt entities.
org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity	getApplicationAttemptEntity(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, String fields, Map<String,String> filters) Gets application attempt entity.
org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity	getApplicationEntity(org.apache.hadoop.yarn.api.records.ApplicationId appId, String fields, Map<String,String> filters) Gets application entity.
List<org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity>	getContainerEntities(org.apache.hadoop.yarn.api.records.ApplicationId appId, String fields, Map<String,String> filters, long limit, String fromId) Gets container entities for an application.
org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity	getContainerEntity(org.apache.hadoop.yarn.api.records.ContainerId containerId, String fields, Map<String,String> filters) Gets Timeline entity for the container.
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.hadoop.yarn.client.api.TimelineReaderClient

createTimelineReaderClient

Methods inherited from class org.apache.hadoop.service.CompositeService

addIfService, addService, getServices, removeService, serviceStart, serviceStop

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Constructor Detail

TimelineReaderClientImpl

public TimelineReaderClientImpl()

Method Detail

serviceInit

protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
                    throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.CompositeService

Throws:

Exception

getApplicationEntity

public org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity getApplicationEntity(org.apache.hadoop.yarn.api.records.ApplicationId appId,
                                                                                              String fields,
                                                                                              Map<String,String> filters)
                                                                                       throws IOException

Description copied from class: TimelineReaderClient

Gets application entity.

Specified by:

getApplicationEntity in class TimelineReaderClient

Parameters:

appId - application id

fields - Fields to be fetched. Defaults to INFO.

filters - Filters to be applied while fetching entities.

Returns:

entity of the application

Throws:

IOException - io error occur.

getApplicationAttemptEntity

public org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity getApplicationAttemptEntity(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
                                                                                                     String fields,
                                                                                                     Map<String,String> filters)
                                                                                              throws IOException

Description copied from class: TimelineReaderClient

Gets application attempt entity.

Specified by:

getApplicationAttemptEntity in class TimelineReaderClient

Parameters:

appAttemptId - application attempt id

fields - Fields to be fetched. Defaults to INFO.

filters - Filters to be applied while fetching entities.

Returns:

entity associated with application attempt

Throws:

IOException - io error occur.

getApplicationAttemptEntities

public List<org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity> getApplicationAttemptEntities(org.apache.hadoop.yarn.api.records.ApplicationId appId,
                                                                                                             String fields,
                                                                                                             Map<String,String> filters,
                                                                                                             long limit,
                                                                                                             String fromId)
                                                                                                      throws IOException

Description copied from class: TimelineReaderClient

Gets application attempt entities.

Specified by:

getApplicationAttemptEntities in class TimelineReaderClient

Parameters:

appId - application id

fields - Fields to be fetched. Defaults to INFO.

filters - Filters to be applied while fetching entities.

limit - Number of entities to return.

fromId - Retrieve next set of generic ids from given fromId

Returns:

list of application attempt entities

Throws:

IOException - io error occur.

getContainerEntity

public org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity getContainerEntity(org.apache.hadoop.yarn.api.records.ContainerId containerId,
                                                                                            String fields,
                                                                                            Map<String,String> filters)
                                                                                     throws IOException

Description copied from class: TimelineReaderClient

Gets Timeline entity for the container.

Specified by:

getContainerEntity in class TimelineReaderClient

Parameters:

containerId - container id

fields - Fields to be fetched. Defaults to INFO.

filters - Filters to be applied while fetching entities.

Returns:

timeline entity for container

Throws:

IOException - io error occur.

getContainerEntities

public List<org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity> getContainerEntities(org.apache.hadoop.yarn.api.records.ApplicationId appId,
                                                                                                    String fields,
                                                                                                    Map<String,String> filters,
                                                                                                    long limit,
                                                                                                    String fromId)
                                                                                             throws IOException

Description copied from class: TimelineReaderClient

Gets container entities for an application.

Specified by:

getContainerEntities in class TimelineReaderClient

Parameters:

appId - application id

fields - Fields to be fetched. Defaults to INFO.

filters - Filters to be applied while fetching entities.

limit - Number of entities to return.

fromId - Retrieve next set of generic ids from given fromId

Returns:

list of entities

Throws:

IOException - io error occur.

encodeValue

@VisibleForTesting
protected String encodeValue(String value)
                                         throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

doGetUri

@VisibleForTesting
protected com.sun.jersey.api.client.ClientResponse doGetUri(URI base,
                                                                               String path,
                                                                               javax.ws.rs.core.MultivaluedMap<String,String> params)
                                                                        throws IOException

Throws:

IOException