Class 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>
    A BulkWriter implementation that writes data in ORC format.
    • Method Detail

      • addElement

        public void addElement​(T element)
                        throws IOException
        Specified by:
        addElement in interface org.apache.flink.api.common.serialization.BulkWriter<T>
        Throws:
        IOException
      • flush

        public void flush()
                   throws IOException
        Specified by:
        flush in interface org.apache.flink.api.common.serialization.BulkWriter<T>
        Throws:
        IOException
      • finish

        public void finish()
                    throws IOException
        Specified by:
        finish in interface org.apache.flink.api.common.serialization.BulkWriter<T>
        Throws:
        IOException