public class FileBufferPersistWriter extends Object implements StreamsPersistWriter, Serializable
Constructor and Description |
---|
FileBufferPersistWriter() |
FileBufferPersistWriter(FileBufferConfiguration config) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
String |
getId() |
void |
prepare(Object configurationObject) |
void |
write(StreamsDatum entry) |
public FileBufferPersistWriter()
public FileBufferPersistWriter(FileBufferConfiguration config)
public String getId()
getId
in interface StreamsOperation
public void write(StreamsDatum entry)
write
in interface StreamsPersistWriter
public void prepare(Object configurationObject)
prepare
in interface StreamsOperation
public void cleanUp()
cleanUp
in interface StreamsOperation
Copyright © 2017 The Apache Software Foundation. All rights reserved.