org.apache.paimon.operation

Class RawFileSplitRead

java.lang.Object

org.apache.paimon.operation.RawFileSplitRead

All Implemented Interfaces:

SplitRead<InternalRow>

public class RawFileSplitRead
extends Object
implements SplitRead<InternalRow>

A SplitRead to read raw file directly from DataSplit.

Constructor Summary

Constructors

Constructor and Description
RawFileSplitRead(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, RowType rowType, FileFormatDiscover formatDiscover, FileStorePathFactory pathFactory, boolean fileIndexReadEnabled)

Method Summary

Modifier and Type	Method and Description
RecordReader<InternalRow>	createReader(BinaryRow partition, int bucket, List<DataFileMeta> files, List<IOExceptionSupplier<DeletionVector>> dvFactories)
RecordReader<InternalRow>	createReader(DataSplit split) Create a RecordReader from split.
SplitRead<InternalRow>	forceKeepDelete()
RawFileSplitRead	withFilter(Predicate predicate)
SplitRead<InternalRow>	withIOManager(IOManager ioManager)
SplitRead<InternalRow>	withReadType(RowType readRowType)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.operation.SplitRead

convert

Constructor Detail

RawFileSplitRead

public RawFileSplitRead(FileIO fileIO,
                        SchemaManager schemaManager,
                        TableSchema schema,
                        RowType rowType,
                        FileFormatDiscover formatDiscover,
                        FileStorePathFactory pathFactory,
                        boolean fileIndexReadEnabled)

Method Detail

forceKeepDelete

public SplitRead<InternalRow> forceKeepDelete()

Specified by:

forceKeepDelete in interface SplitRead<InternalRow>

withIOManager

public SplitRead<InternalRow> withIOManager(@Nullable
                                            IOManager ioManager)

Specified by:

withIOManager in interface SplitRead<InternalRow>

withReadType

public SplitRead<InternalRow> withReadType(RowType readRowType)

Specified by:

withReadType in interface SplitRead<InternalRow>

withFilter

public RawFileSplitRead withFilter(Predicate predicate)

Specified by:

withFilter in interface SplitRead<InternalRow>

createReader

public RecordReader<InternalRow> createReader(DataSplit split)
                                       throws IOException

Description copied from interface: SplitRead

Create a RecordReader from split.

Specified by:

createReader in interface SplitRead<InternalRow>

Throws:

IOException

createReader

public RecordReader<InternalRow> createReader(BinaryRow partition,
                                              int bucket,
                                              List<DataFileMeta> files,
                                              @Nullable
                                              List<IOExceptionSupplier<DeletionVector>> dvFactories)
                                       throws IOException

Throws:

IOException