co.cask.cdap.data.stream

Interface StreamFileWriterFactory

All Known Implementing Classes:

InMemoryStreamFileWriterFactory, LocationStreamFileWriterFactory

public interface StreamFileWriterFactory

Method Summary

Methods

Modifier and Type	Method and Description
FileWriter<co.cask.cdap.api.flow.flowlet.StreamEvent>	create(StreamConfig config, int generation)
String	getFileNamePrefix() Returns the file name prefix of all stream files created through this factory.

Method Detail

getFileNamePrefix

String getFileNamePrefix()

Returns the file name prefix of all stream files created through this factory.

create

FileWriter<co.cask.cdap.api.flow.flowlet.StreamEvent> create(StreamConfig config,
                                                           int generation)
                                                             throws IOException

Throws:

IOException