org.apache.paimon.hive.mapred

Class PaimonOutputFormat

java.lang.Object

org.apache.paimon.hive.mapred.PaimonOutputFormat

All Implemented Interfaces:

org.apache.hadoop.hive.ql.io.HiveOutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>, org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>

Direct Known Subclasses:

TableStoreOutputFormat

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 Summary

Constructors

Constructor and Description
PaimonOutputFormat()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

PaimonOutputFormat

public PaimonOutputFormat()

Method Detail

getRecordWriter

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

Specified by:

getRecordWriter in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>

Throws:

IOException

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem fileSystem,
                             org.apache.hadoop.mapred.JobConf jobConf)
                      throws IOException

Specified by:

checkOutputSpecs in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>

Throws:

IOException

getHiveRecordWriter

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

Specified by:

getHiveRecordWriter in interface org.apache.hadoop.hive.ql.io.HiveOutputFormat<org.apache.hadoop.io.NullWritable,RowDataContainer>

Throws:

IOException