Package org.apache.flink.orc.writer
Class OrcBulkWriter<T>
- java.lang.Object
-
- org.apache.flink.orc.writer.OrcBulkWriter<T>
-
- Type Parameters:
T- The type of element written.
- All Implemented Interfaces:
org.apache.flink.api.common.serialization.BulkWriter<T>
@Internal public class OrcBulkWriter<T> extends Object implements org.apache.flink.api.common.serialization.BulkWriter<T>
ABulkWriterimplementation that writes data in ORC format.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.BulkWriter
org.apache.flink.api.common.serialization.BulkWriter.Factory<T extends Object>
-
-
-
-
Method Detail
-
addElement
public void addElement(T element) throws IOException
- Specified by:
addElementin interfaceorg.apache.flink.api.common.serialization.BulkWriter<T>- Throws:
IOException
-
flush
public void flush() throws IOException- Specified by:
flushin interfaceorg.apache.flink.api.common.serialization.BulkWriter<T>- Throws:
IOException
-
finish
public void finish() throws IOException- Specified by:
finishin interfaceorg.apache.flink.api.common.serialization.BulkWriter<T>- Throws:
IOException
-
-