Package org.apache.beam.sdk.io.iceberg.cdc

Class DeleteReader.PreloadedDeletes

java.lang.Object

org.apache.beam.sdk.io.iceberg.cdc.DeleteReader.PreloadedDeletes

Enclosing class:

DeleteReader<T>

public static final class DeleteReader.PreloadedDeletes
extends Object

Delete data already loaded by a planning/pushdown path for one task read.

Method Summary

Modifier and Type	Method	Description
static DeleteReader.PreloadedDeletes	empty()
@Nullable org.apache.iceberg.util.StructLikeSet	equalityDeleteSet(Set<Integer> equalityFieldIds)
static DeleteReader.PreloadedDeletes	of(@Nullable org.apache.iceberg.deletes.PositionDeleteIndex positionDeleteIndex, Map<Set<Integer>,org.apache.iceberg.util.StructLikeSet> equalityDeleteSets)
@Nullable org.apache.iceberg.deletes.PositionDeleteIndex	positionDeleteIndex()

Methods inherited from class java.lang.Object

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

Method Details

empty

public static DeleteReader.PreloadedDeletes empty()

of

public static DeleteReader.PreloadedDeletes of(@Nullable org.apache.iceberg.deletes.PositionDeleteIndex positionDeleteIndex,
 Map<Set<Integer>,org.apache.iceberg.util.StructLikeSet> equalityDeleteSets)

positionDeleteIndex

public @Nullable org.apache.iceberg.deletes.PositionDeleteIndex positionDeleteIndex()

equalityDeleteSet

public @Nullable org.apache.iceberg.util.StructLikeSet equalityDeleteSet(Set<Integer> equalityFieldIds)