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

Class CosmosDBDocumentStoreWriter<TimelineDoc extends TimelineDocument>

java.lang.Object

org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb.CosmosDBDocumentStoreWriter<TimelineDoc>

All Implemented Interfaces:

AutoCloseable, DocumentStoreWriter<TimelineDoc>

public class CosmosDBDocumentStoreWriter<TimelineDoc extends TimelineDocument>
extends Object
implements DocumentStoreWriter<TimelineDoc>

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
void	createCollection(String collectionName)
void	createDatabase()
void	writeDocument(TimelineDoc timelineDoc, CollectionType collectionType)

Methods inherited from class java.lang.Object

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

Constructor Details

CosmosDBDocumentStoreWriter

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

Method Details

createDatabase

public void createDatabase()

Specified by:

createDatabase in interface DocumentStoreWriter<TimelineDoc extends TimelineDocument>

createCollection

public void createCollection(String collectionName)

Specified by:

createCollection in interface DocumentStoreWriter<TimelineDoc extends TimelineDocument>

writeDocument

public void writeDocument(TimelineDoc timelineDoc,
 CollectionType collectionType)

Specified by:

writeDocument in interface DocumentStoreWriter<TimelineDoc extends TimelineDocument>

close

public void close()

Specified by:

close in interface AutoCloseable