public class HiveOutputFormatFactory extends Object implements OutputFormatFactory<Row>
OutputFormatFactory
, use FileSinkOperator.RecordWriter
to write record.Constructor and Description |
---|
HiveOutputFormatFactory(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.flink.connectors.hive.HiveOutputFormatFactory.HiveOutputFormat |
createOutputFormat(Path outPath)
Create a
OutputFormat with specific path. |
public HiveOutputFormatFactory(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.flink.connectors.hive.HiveOutputFormatFactory.HiveOutputFormat createOutputFormat(Path outPath)
OutputFormatFactory
OutputFormat
with specific path.createOutputFormat
in interface OutputFormatFactory<Row>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.