org.apache.flink.connectors.hive.write

Class HiveBulkWriterFactory

java.lang.Object

org.apache.flink.connectors.hive.write.HiveBulkWriterFactory

All Implemented Interfaces:

Serializable, org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter.Factory<org.apache.flink.table.data.RowData>

public class HiveBulkWriterFactory
extends Object
implements org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter.Factory<org.apache.flink.table.data.RowData>

Hive bulk writer factory for path-based bulk file writer that writes to the specific hadoop path.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveBulkWriterFactory(HiveWriterFactory factory)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter<org.apache.flink.table.data.RowData>	create(org.apache.hadoop.fs.Path targetPath, org.apache.hadoop.fs.Path inProgressPath)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveBulkWriterFactory

public HiveBulkWriterFactory(HiveWriterFactory factory)

Method Detail

create

public org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter<org.apache.flink.table.data.RowData> create(org.apache.hadoop.fs.Path targetPath,
                                                                                                                  org.apache.hadoop.fs.Path inProgressPath)
                                                                                                           throws IOException

Specified by:

create in interface org.apache.flink.formats.hadoop.bulk.HadoopPathBasedBulkWriter.Factory<org.apache.flink.table.data.RowData>

Throws:

IOException