co.cask.cdap.data.runtime

Class LocationStreamFileWriterFactory

java.lang.Object

co.cask.cdap.data.runtime.LocationStreamFileWriterFactory

All Implemented Interfaces:

StreamFileWriterFactory

public final class LocationStreamFileWriterFactory
extends Object
implements StreamFileWriterFactory

A StreamFileWriterFactory that provides FileWriter which writes to file location. Use for both local and distributed mode.

Constructor Summary

Constructors

Constructor and Description
LocationStreamFileWriterFactory(CConfiguration cConf)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocationStreamFileWriterFactory

@Inject
public LocationStreamFileWriterFactory(CConfiguration cConf)

Method Detail

getFileNamePrefix

public String getFileNamePrefix()

Description copied from interface: StreamFileWriterFactory

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

Specified by:

getFileNamePrefix in interface StreamFileWriterFactory

create

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

Specified by:

create in interface StreamFileWriterFactory

Throws:

IOException