Package org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb

Class CosmosDBDocumentStoreReader<TimelineDoc extends TimelineDocument>

java.lang.Object

org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb.CosmosDBDocumentStoreReader<TimelineDoc>

All Implemented Interfaces:

AutoCloseable, DocumentStoreReader<TimelineDoc>

public class CosmosDBDocumentStoreReader<TimelineDoc extends TimelineDocument>
extends Object
implements DocumentStoreReader<TimelineDoc>

This is the Document Store Reader implementation for DocumentStoreVendor.COSMOS_DB.

Constructor Summary

Constructors

Constructor	Description
CosmosDBDocumentStoreReader(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	close()
Set<String>	fetchEntityTypes(String collectionName, org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context)
TimelineDoc	readDocument(String collectionName, org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context, Class<TimelineDoc> timelineDocClass)
List<TimelineDoc>	readDocumentList(String collectionName, org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context, Class<TimelineDoc> timelineDocClass, long size)

Methods inherited from class java.lang.Object

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

Constructor Details

CosmosDBDocumentStoreReader

public CosmosDBDocumentStoreReader(org.apache.hadoop.conf.Configuration conf)

Method Details

readDocumentList

public List<TimelineDoc> readDocumentList(String collectionName,
 org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context,
 Class<TimelineDoc> timelineDocClass,
 long size)
                                   throws NoDocumentFoundException

Specified by:

readDocumentList in interface DocumentStoreReader<TimelineDoc extends TimelineDocument>

Throws:

NoDocumentFoundException

fetchEntityTypes

public Set<String> fetchEntityTypes(String collectionName,
 org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context)

Specified by:

fetchEntityTypes in interface DocumentStoreReader<TimelineDoc extends TimelineDocument>

readDocument

public TimelineDoc readDocument(String collectionName,
 org.apache.hadoop.yarn.server.timelineservice.reader.TimelineReaderContext context,
 Class<TimelineDoc> timelineDocClass)
                         throws NoDocumentFoundException

Specified by:

readDocument in interface DocumentStoreReader<TimelineDoc extends TimelineDocument>

Throws:

NoDocumentFoundException

close

public void close()

Specified by:

close in interface AutoCloseable