org.apache.paimon.operation

Interface SplitRead<T>

Type Parameters:

T - type of record to read.

All Known Implementing Classes:

IncrementalCompactDiffSplitRead, IncrementalDiffSplitRead, MergeFileSplitRead, RawFileSplitRead

public interface SplitRead<T>

Read operation which provides RecordReader creation.

Method Summary

Modifier and Type	Method and Description
static <L,R> SplitRead<R>	convert(SplitRead<L> read, IOFunction<DataSplit,RecordReader<R>> convertedFactory)
RecordReader<T>	createReader(DataSplit split) Create a RecordReader from split.
SplitRead<T>	forceKeepDelete()
SplitRead<T>	withFilter(Predicate predicate)
SplitRead<T>	withIOManager(IOManager ioManager)
SplitRead<T>	withReadType(RowType readType)

Method Detail

forceKeepDelete

SplitRead<T> forceKeepDelete()

withIOManager

SplitRead<T> withIOManager(@Nullable
                           IOManager ioManager)

withReadType

SplitRead<T> withReadType(RowType readType)

withFilter

SplitRead<T> withFilter(@Nullable
                        Predicate predicate)

createReader

RecordReader<T> createReader(DataSplit split)
                      throws IOException

Create a RecordReader from split.

Throws:

IOException

convert

static <L,R> SplitRead<R> convert(SplitRead<L> read,
                                  IOFunction<DataSplit,RecordReader<R>> convertedFactory)