org.apache.paimon.table.source.splitread

Class IncrementalChangelogReadProvider

java.lang.Object

org.apache.paimon.table.source.splitread.IncrementalChangelogReadProvider

All Implemented Interfaces:

SplitReadProvider

public class IncrementalChangelogReadProvider
extends Object
implements SplitReadProvider

A SplitReadProvider to incremental changelog read.

Constructor Summary

Constructors

Constructor and Description
IncrementalChangelogReadProvider(java.util.function.Supplier<MergeFileSplitRead> 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

IncrementalChangelogReadProvider

public IncrementalChangelogReadProvider(java.util.function.Supplier<MergeFileSplitRead> 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