public class IncrementalChangelogReadProvider extends Object implements SplitReadProvider
SplitReadProvider
to incremental changelog read.Constructor and Description |
---|
IncrementalChangelogReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier,
java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner) |
Modifier and Type | Method and Description |
---|---|
SplitRead<InternalRow> |
getOrCreate() |
boolean |
initialized() |
boolean |
match(DataSplit split,
boolean forceKeepDelete) |
public IncrementalChangelogReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)
public boolean match(DataSplit split, boolean forceKeepDelete)
match
in interface SplitReadProvider
public boolean initialized()
initialized
in interface SplitReadProvider
public SplitRead<InternalRow> getOrCreate()
getOrCreate
in interface SplitReadProvider
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.