public class IncrementalDiffSplitRead extends Object implements SplitRead<InternalRow>
SplitRead
for batch incremental diff.Constructor and Description |
---|
IncrementalDiffSplitRead(MergeFileSplitRead mergeRead) |
Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
createReader(DataSplit split)
Create a
RecordReader from split. |
SplitRead<InternalRow> |
forceKeepDelete() |
SplitRead<InternalRow> |
withFilter(Predicate predicate) |
SplitRead<InternalRow> |
withIOManager(IOManager ioManager) |
SplitRead<InternalRow> |
withReadType(RowType readType) |
public IncrementalDiffSplitRead(MergeFileSplitRead mergeRead)
public SplitRead<InternalRow> forceKeepDelete()
forceKeepDelete
in interface SplitRead<InternalRow>
public SplitRead<InternalRow> withIOManager(@Nullable IOManager ioManager)
withIOManager
in interface SplitRead<InternalRow>
public SplitRead<InternalRow> withReadType(RowType readType)
withReadType
in interface SplitRead<InternalRow>
public SplitRead<InternalRow> withFilter(@Nullable Predicate predicate)
withFilter
in interface SplitRead<InternalRow>
public RecordReader<InternalRow> createReader(DataSplit split) throws IOException
SplitRead
RecordReader
from split.createReader
in interface SplitRead<InternalRow>
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.