org.apache.hadoop.yarn.server.timelineservice.storage

Class HBaseTimelineReaderImpl

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, org.apache.hadoop.yarn.server.timelineservice.storage.TimelineReader

public class HBaseTimelineReaderImpl
extends org.apache.hadoop.service.AbstractService
implements org.apache.hadoop.yarn.server.timelineservice.storage.TimelineReader

HBase based implementation for TimelineReader.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.yarn.server.timelineservice.storage.TimelineReader

org.apache.hadoop.yarn.server.timelineservice.storage.TimelineReader.Field

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

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor and Description
HBaseTimelineReaderImpl()

Method Summary

Methods

Modifier and Type	Method and Description
Set<org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity>	getEntities(org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context, org.apache.hadoop.yarn.server.timelineservice.reader.TimelineEntityFilters filters, org.apache.hadoop.yarn.server.timelineservice.reader.TimelineDataToRetrieve dataToRetrieve)
org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity	getEntity(org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context, org.apache.hadoop.yarn.server.timelineservice.reader.TimelineDataToRetrieve dataToRetrieve)
Set<String>	getEntityTypes(org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context)
void	serviceInit(org.apache.hadoop.conf.Configuration conf)
protected void	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, serviceStart, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.service.Service

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, registerServiceListener, start, stop, unregisterServiceListener, waitForServiceToStop

Constructor Detail

HBaseTimelineReaderImpl

public HBaseTimelineReaderImpl()

Method Detail

serviceInit

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

Overrides:

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

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

Throws:

Exception

getEntity

public org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity getEntity(org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context,
                                                                          org.apache.hadoop.yarn.server.timelineservice.reader.TimelineDataToRetrieve dataToRetrieve)
                                                                            throws IOException

Specified by:

getEntity in interface org.apache.hadoop.yarn.server.timelineservice.storage.TimelineReader

Throws:

IOException

getEntities

public Set<org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity> getEntities(org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context,
                                                                                 org.apache.hadoop.yarn.server.timelineservice.reader.TimelineEntityFilters filters,
                                                                                 org.apache.hadoop.yarn.server.timelineservice.reader.TimelineDataToRetrieve dataToRetrieve)
                                                                                   throws IOException

Specified by:

getEntities in interface org.apache.hadoop.yarn.server.timelineservice.storage.TimelineReader

Throws:

IOException

getEntityTypes

public Set<String> getEntityTypes(org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context)
                           throws IOException

Specified by:

getEntityTypes in interface org.apache.hadoop.yarn.server.timelineservice.storage.TimelineReader

Throws:

IOException