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

Class FileContentWriterFactory

java.lang.Object

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

All Implemented Interfaces:

ContentWriterFactory

public final class FileContentWriterFactory
extends Object
implements ContentWriterFactory

A ContentWriterFactory that creates ContentWriter that will write events to file directly.

Constructor Summary

Constructors

Constructor and Description
FileContentWriterFactory(StreamConfig streamConfig, 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

FileContentWriterFactory

public FileContentWriterFactory(StreamConfig streamConfig,
                        ConcurrentStreamWriter streamWriter,
                        Map<String,String> headers)
                         throws IOException

Throws:

IOException

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