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

Interface ContentWriterFactory

All Known Implementing Classes:

BufferedContentWriterFactory, FileContentWriterFactory, LengthBasedContentWriterFactory

public interface ContentWriterFactory

Factory for creating ContentWriter.

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.

Method Detail

getStream

Id.Stream getStream()

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

create

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

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

Throws:

IOException