org.apache.flink.connectors.hive.write

类 HiveWriterFactory

java.lang.Object

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

所有已实现的接口:

Serializable

public class HiveWriterFactory
extends Object
implements Serializable

Factory for creating FileSinkOperator.RecordWriter and converters for writing.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
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)

方法概要

限定符和类型	方法和说明
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()

从类继承的方法 java.lang.Object

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

构造器详细资料

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)

方法详细资料

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()