org.apache.paimon.table.source.splitread

Class RawFileSplitReadProvider

java.lang.Object

org.apache.paimon.table.source.splitread.RawFileSplitReadProvider

All Implemented Interfaces:

SplitReadProvider

public class RawFileSplitReadProvider
extends Object
implements SplitReadProvider

A SplitReadProvider to create RawFileSplitRead.

Constructor Summary

Constructors

Constructor and Description
RawFileSplitReadProvider(java.util.function.Supplier<RawFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)

Method Summary

Modifier and Type	Method and Description
SplitRead<InternalRow>	getOrCreate()
boolean	initialized()
boolean	match(DataSplit split, boolean forceKeepDelete)

Methods inherited from class java.lang.Object

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

Constructor Detail

RawFileSplitReadProvider

public RawFileSplitReadProvider(java.util.function.Supplier<RawFileSplitRead> supplier,
                                java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)

Method Detail

match

public boolean match(DataSplit split,
                     boolean forceKeepDelete)

Specified by:

match in interface SplitReadProvider

initialized

public boolean initialized()

Specified by:

initialized in interface SplitReadProvider

getOrCreate

public SplitRead<InternalRow> getOrCreate()

Specified by:

getOrCreate in interface SplitReadProvider