org.apache.paimon.hive.mapred

Class PaimonInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

org.apache.hadoop.mapred.FileSplit

org.apache.paimon.hive.mapred.PaimonInputSplit

All Implemented Interfaces:

org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit, org.apache.hadoop.mapred.InputSplitWithLocationInfo

public class PaimonInputSplit
extends org.apache.hadoop.mapred.FileSplit

FileSplit for paimon. It contains all files to read from a certain partition and bucket.

Constructor Summary

Constructors

Constructor and Description
PaimonInputSplit()
PaimonInputSplit(String path, DataSplit split, FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getLength()
String[]	getLocations()
org.apache.hadoop.fs.Path	getPath()
long	getStart()
FileStoreTable	getTable()
int	hashCode()
void	readFields(DataInput dataInput)
DataSplit	split()
String	toString()
void	write(DataOutput dataOutput)

Methods inherited from class org.apache.hadoop.mapred.FileSplit

getLocationInfo

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

PaimonInputSplit

public PaimonInputSplit()

PaimonInputSplit

public PaimonInputSplit(String path,
                        DataSplit split,
                        FileStoreTable table)

Method Detail

split

public DataSplit split()

getPath

public org.apache.hadoop.fs.Path getPath()

Overrides:

getPath in class org.apache.hadoop.mapred.FileSplit

getStart

public long getStart()

Overrides:

getStart in class org.apache.hadoop.mapred.FileSplit

getLength

public long getLength()

Specified by:

getLength in interface org.apache.hadoop.mapred.InputSplit

Overrides:

getLength in class org.apache.hadoop.mapred.FileSplit

getLocations

public String[] getLocations()

Specified by:

getLocations in interface org.apache.hadoop.mapred.InputSplit

Overrides:

getLocations in class org.apache.hadoop.mapred.FileSplit

getTable

public FileStoreTable getTable()

write

public void write(DataOutput dataOutput)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Overrides:

write in class org.apache.hadoop.mapred.FileSplit

Throws:

IOException

readFields

public void readFields(DataInput dataInput)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Overrides:

readFields in class org.apache.hadoop.mapred.FileSplit

Throws:

IOException

toString

public String toString()

Overrides:

toString in class org.apache.hadoop.mapred.FileSplit

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object