org.apache.flink.orc.nohive

Class OrcNoHiveBulkWriterFactory

java.lang.Object

org.apache.flink.orc.nohive.OrcNoHiveBulkWriterFactory

All Implemented Interfaces:

Serializable, BulkWriter.Factory<RowData>

public class OrcNoHiveBulkWriterFactory
extends Object
implements BulkWriter.Factory<RowData>

A BulkWriter.Factory from orc no-hive version.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OrcNoHiveBulkWriterFactory(Configuration conf, String schema, LogicalType[] fieldTypes)

Method Summary

Modifier and Type	Method and Description
BulkWriter<RowData>	create(FSDataOutputStream out) Creates a writer that writes to the given stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OrcNoHiveBulkWriterFactory

public OrcNoHiveBulkWriterFactory(Configuration conf,
                                  String schema,
                                  LogicalType[] fieldTypes)

Method Detail

create

public BulkWriter<RowData> create(FSDataOutputStream out)
                           throws IOException

Description copied from interface: BulkWriter.Factory

Creates a writer that writes to the given stream.

Specified by:

create in interface BulkWriter.Factory<RowData>

Parameters:

out - The output stream to write the encoded data to.

Throws:

IOException - Thrown if the writer cannot be opened, or if the output stream throws an exception.