public abstract static class ThriftIO.Sink<T extends org.apache.thrift.TBase<?,?>> extends java.lang.Object implements FileIO.Sink<T>
ThriftIO.sink(org.apache.thrift.protocol.TProtocolFactory)
.Constructor and Description |
---|
Sink() |
Modifier and Type | Method and Description |
---|---|
void |
flush()
Flushes the buffered state (if any) before the channel is closed.
|
void |
open(java.nio.channels.WritableByteChannel channel)
Initializes writing to the given channel.
|
void |
write(T element)
Appends a single element to the file.
|
public void open(java.nio.channels.WritableByteChannel channel) throws java.io.IOException
FileIO.Sink
FileIO.Sink
instance.open
in interface FileIO.Sink<T extends org.apache.thrift.TBase<?,?>>
java.io.IOException
public void write(T element) throws java.io.IOException
FileIO.Sink
write
in interface FileIO.Sink<T extends org.apache.thrift.TBase<?,?>>
java.io.IOException
public void flush() throws java.io.IOException
FileIO.Sink
flush
in interface FileIO.Sink<T extends org.apache.thrift.TBase<?,?>>
java.io.IOException