org.apache.flink.connectors.hive.write

Class HiveWriterFactory

java.lang.Object

org.apache.flink.connectors.hive.write.HiveWriterFactory

All Implemented Interfaces:

Serializable

public class HiveWriterFactory
extends Object
implements Serializable

Factory for creating FileSinkOperator.RecordWriter and converters for writing.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveWriterFactory(org.apache.hadoop.mapred.JobConf jobConf, Class hiveOutputFormatClz, org.apache.hadoop.hive.metastore.api.SerDeInfo serDeInfo, org.apache.flink.table.api.TableSchema schema, String[] partitionColumns, Properties tableProperties, HiveShim hiveShim, boolean isCompressed)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter	createRecordWriter(org.apache.hadoop.fs.Path path) Create a FileSinkOperator.RecordWriter from path.
java.util.function.Function<org.apache.flink.types.Row,org.apache.hadoop.io.Writable>	createRowConverter()
java.util.function.Function<org.apache.flink.table.data.RowData,org.apache.hadoop.io.Writable>	createRowDataConverter()
org.apache.hadoop.mapred.JobConf	getJobConf()

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveWriterFactory

public HiveWriterFactory(org.apache.hadoop.mapred.JobConf jobConf,
                         Class hiveOutputFormatClz,
                         org.apache.hadoop.hive.metastore.api.SerDeInfo serDeInfo,
                         org.apache.flink.table.api.TableSchema schema,
                         String[] partitionColumns,
                         Properties tableProperties,
                         HiveShim hiveShim,
                         boolean isCompressed)

Method Detail

createRecordWriter

public org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter createRecordWriter(org.apache.hadoop.fs.Path path)

Create a FileSinkOperator.RecordWriter from path.

getJobConf

public org.apache.hadoop.mapred.JobConf getJobConf()

createRowConverter

public java.util.function.Function<org.apache.flink.types.Row,org.apache.hadoop.io.Writable> createRowConverter()

createRowDataConverter

public java.util.function.Function<org.apache.flink.table.data.RowData,org.apache.hadoop.io.Writable> createRowDataConverter()