public class PaimonOutputFormat extends Object implements org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>, org.apache.hadoop.hive.ql.io.HiveOutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>
OutputFormat
for table split.Constructor and Description |
---|
PaimonOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.mapred.JobConf jobConf) |
org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter |
getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.fs.Path path,
Class<? extends org.apache.hadoop.io.Writable> aClass,
boolean b,
Properties properties,
org.apache.hadoop.util.Progressable progressable) |
org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,RowDataContainer> |
getRecordWriter(org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.mapred.JobConf jobConf,
String s,
org.apache.hadoop.util.Progressable progressable) |
public org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,RowDataContainer> getRecordWriter(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.mapred.JobConf jobConf, String s, org.apache.hadoop.util.Progressable progressable) throws IOException
getRecordWriter
in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>
IOException
public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.mapred.JobConf jobConf) throws IOException
checkOutputSpecs
in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>
IOException
public org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.fs.Path path, Class<? extends org.apache.hadoop.io.Writable> aClass, boolean b, Properties properties, org.apache.hadoop.util.Progressable progressable) throws IOException
getHiveRecordWriter
in interface org.apache.hadoop.hive.ql.io.HiveOutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.