co.cask.cdap.data.stream.service.upload

Class BufferedContentWriterFactory

java.lang.Object

co.cask.cdap.data.stream.service.upload.BufferedContentWriterFactory

All Implemented Interfaces:

ContentWriterFactory

public final class BufferedContentWriterFactory
extends Object
implements ContentWriterFactory

A ContentWriterFactory that creates ContentWriter that buffer all write requests in memory and write them out at close time.

Constructor Summary

Constructors

Constructor and Description
BufferedContentWriterFactory(Id.Stream streamId, ConcurrentStreamWriter streamWriter, Map<String,String> headers)

Method Summary

Methods

Modifier and Type	Method and Description
ContentWriter	create(Map<String,String> headers) Creates a ContentWriter with the given set of event headers added to each StreamEvent written through the ContentWriter returned.
Id.Stream	getStream() Returns the Id of the stream that all ContentWriter created by this factory will write to.

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferedContentWriterFactory

public BufferedContentWriterFactory(Id.Stream streamId,
                            ConcurrentStreamWriter streamWriter,
                            Map<String,String> headers)

Method Detail

getStream

public Id.Stream getStream()

Description copied from interface: ContentWriterFactory

Returns the Id of the stream that all ContentWriter created by this factory will write to.

Specified by:

getStream in interface ContentWriterFactory

create

public ContentWriter create(Map<String,String> headers)
                     throws IOException

Description copied from interface: ContentWriterFactory

Creates a ContentWriter with the given set of event headers added to each StreamEvent written through the ContentWriter returned.

Specified by:

create in interface ContentWriterFactory

Throws:

IOException