org.apache.flink.connectors.hive.write

Class HiveOutputFormatFactory

java.lang.Object

org.apache.flink.connectors.hive.write.HiveOutputFormatFactory

All Implemented Interfaces:

Serializable, OutputFormatFactory<Row>

public class HiveOutputFormatFactory
extends Object
implements OutputFormatFactory<Row>

Hive OutputFormatFactory, use FileSinkOperator.RecordWriter to write record.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveOutputFormatFactory(HiveWriterFactory factory)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.connectors.hive.write.HiveOutputFormatFactory.HiveOutputFormat	createOutputFormat(Path path) Create a OutputFormat with specific path.

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveOutputFormatFactory

public HiveOutputFormatFactory(HiveWriterFactory factory)

Method Detail

createOutputFormat

public org.apache.flink.connectors.hive.write.HiveOutputFormatFactory.HiveOutputFormat createOutputFormat(Path path)

Description copied from interface: OutputFormatFactory

Create a OutputFormat with specific path.

Specified by:

createOutputFormat in interface OutputFormatFactory<Row>