org.apache.flink.connectors.hive.write

Class HiveBulkWriterFactory

java.lang.Object

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

All Implemented Interfaces:

Serializable, HadoopPathBasedBulkWriter.Factory<RowData>

public class HiveBulkWriterFactory
extends Object
implements HadoopPathBasedBulkWriter.Factory<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
HadoopPathBasedBulkWriter<RowData>	create(org.apache.hadoop.fs.Path targetPath, org.apache.hadoop.fs.Path inProgressPath) Creates a path-based writer that writes to the inProgressPath first and commits to targetPath finally.

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 HadoopPathBasedBulkWriter<RowData> create(org.apache.hadoop.fs.Path targetPath,
                                                 org.apache.hadoop.fs.Path inProgressPath)
                                          throws IOException

Description copied from interface: HadoopPathBasedBulkWriter.Factory

Creates a path-based writer that writes to the inProgressPath first and commits to targetPath finally.

Specified by:

create in interface HadoopPathBasedBulkWriter.Factory<RowData>

Parameters:

targetPath - The final path to commit to.

inProgressPath - The intermediate path to write to before committing.

Returns:

The created writer.

Throws:

IOException