co.cask.cdap.data.runtime

Class InMemoryStreamFileWriterFactory

java.lang.Object

co.cask.cdap.data.runtime.InMemoryStreamFileWriterFactory

All Implemented Interfaces:

StreamFileWriterFactory

public final class InMemoryStreamFileWriterFactory
extends Object
implements StreamFileWriterFactory

A Mock StreamFileWriterFactory that actually doesn't write to file, but to in memory queue instead.

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

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