Package org.apache.beam.sdk.io

Interface FileIO.Sink<ElementT>

All Superinterfaces:

Serializable

All Known Implementing Classes:

AvroIO.Sink, ParquetIO.Sink, TextIO.Sink, TFRecordIO.Sink, ThriftIO.Sink, XmlIO.Sink

Enclosing class:

FileIO

public static interface FileIO.Sink<ElementT>
extends Serializable

Specifies how to write elements to individual files in FileIO.write() and FileIO.writeDynamic(). A new instance of FileIO.Sink is created for every file being written.

Method Summary

Modifier and Type	Method	Description
void	flush()	Flushes the buffered state (if any) before the channel is closed.
void	open(WritableByteChannel channel)	Initializes writing to the given channel.
void	write(ElementT element)	Appends a single element to the file.

Method Details

open

void open(WritableByteChannel channel)
   throws IOException

Initializes writing to the given channel. Will be invoked once on a given FileIO.Sink instance.

Throws:

IOException

write

void write(ElementT element)
    throws IOException

Appends a single element to the file. May be invoked zero or more times.

Throws:

IOException

flush

void flush()
    throws IOException

Flushes the buffered state (if any) before the channel is closed. Does not need to close the channel. Will be invoked once.

Throws:

IOException