org.apache.paimon.hive.mapred

Class PaimonInputFormat

java.lang.Object

org.apache.paimon.hive.mapred.PaimonInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat<Void,RowDataContainer>

Direct Known Subclasses:

TableStoreInputFormat

public class PaimonInputFormat
extends Object
implements org.apache.hadoop.mapred.InputFormat<Void,RowDataContainer>

InputFormat for paimon. It divides all files into InputSplits (one split per bucket) and creates RecordReader for each split.

Constructor Summary

Constructors

Constructor and Description
PaimonInputFormat()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapred.RecordReader<Void,RowDataContainer>	getRecordReader(org.apache.hadoop.mapred.InputSplit inputSplit, org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.Reporter reporter)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf jobConf, int numSplits)

Methods inherited from class java.lang.Object

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

Constructor Detail

PaimonInputFormat

public PaimonInputFormat()

Method Detail

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf jobConf,
                                                       int numSplits)

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat<Void,RowDataContainer>

getRecordReader

public org.apache.hadoop.mapred.RecordReader<Void,RowDataContainer> getRecordReader(org.apache.hadoop.mapred.InputSplit inputSplit,
                                                                                    org.apache.hadoop.mapred.JobConf jobConf,
                                                                                    org.apache.hadoop.mapred.Reporter reporter)
                                                                             throws IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat<Void,RowDataContainer>

Throws:

IOException