Class TimelineCollectionWriter<Document extends TimelineDocument>

java.lang.Object
org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.TimelineCollectionWriter<Document>

public class TimelineCollectionWriter<Document extends TimelineDocument> extends Object
This is a generic Collection Writer that can be used for writing documents belonging to different CollectionType under a specific DocumentStoreVendor backend.
  • Constructor Details

    • TimelineCollectionWriter

      public TimelineCollectionWriter(CollectionType collectionType, org.apache.hadoop.conf.Configuration conf) throws org.apache.hadoop.yarn.exceptions.YarnException
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
  • Method Details

    • writeDocument

      public void writeDocument(Document timelineDocument)
    • flush

      public void flush()
    • close

      public void close() throws Exception
      Throws:
      Exception