public class HiveWriterFactory extends Object implements Serializable
FileSinkOperator.RecordWriter
and converters for writing.Constructor and Description |
---|
HiveWriterFactory(org.apache.hadoop.mapred.JobConf jobConf,
Class hiveOutputFormatClz,
org.apache.hadoop.hive.metastore.api.SerDeInfo serDeInfo,
TableSchema schema,
String[] partitionColumns,
Properties tableProperties,
HiveShim hiveShim,
boolean isCompressed) |
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<Row,org.apache.hadoop.io.Writable> |
createRowConverter() |
java.util.function.Function<RowData,org.apache.hadoop.io.Writable> |
createRowDataConverter() |
org.apache.hadoop.mapred.JobConf |
getJobConf() |
public HiveWriterFactory(org.apache.hadoop.mapred.JobConf jobConf, Class hiveOutputFormatClz, org.apache.hadoop.hive.metastore.api.SerDeInfo serDeInfo, TableSchema schema, String[] partitionColumns, Properties tableProperties, HiveShim hiveShim, boolean isCompressed)
public org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter createRecordWriter(org.apache.hadoop.fs.Path path)
FileSinkOperator.RecordWriter
from path.public org.apache.hadoop.mapred.JobConf getJobConf()
public java.util.function.Function<Row,org.apache.hadoop.io.Writable> createRowConverter()
public java.util.function.Function<RowData,org.apache.hadoop.io.Writable> createRowDataConverter()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.