Package org.apache.iceberg.deletes

Class Deletes

java.lang.Object

org.apache.iceberg.deletes.Deletes

public class Deletes
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
static <T extends StructLike> CloseableIterable<java.lang.Long>	deletePositions(java.lang.CharSequence dataLocation, java.util.List<CloseableIterable<T>> deleteFiles)
static CloseableIterable<java.lang.Long>	deletePositions(java.lang.CharSequence dataLocation, CloseableIterable<StructLike> deleteFile)
static <T> CloseableIterable<T>	filter(CloseableIterable<T> rows, java.util.function.Function<T,java.lang.Long> rowToPosition, java.util.Set<java.lang.Long> deleteSet)
static <T> CloseableIterable<T>	filter(CloseableIterable<T> rows, java.util.function.Function<T,StructLike> rowToDeleteKey, StructLikeSet deleteSet)
static <T> CloseableIterable<T>	streamingFilter(CloseableIterable<T> rows, java.util.function.Function<T,java.lang.Long> rowToPosition, CloseableIterable<java.lang.Long> posDeletes)
static StructLikeSet	toEqualitySet(CloseableIterable<StructLike> eqDeletes, Types.StructType eqType)
static <T extends StructLike> java.util.Set<java.lang.Long>	toPositionSet(java.lang.CharSequence dataLocation, java.util.List<CloseableIterable<T>> deleteFiles)
static java.util.Set<java.lang.Long>	toPositionSet(java.lang.CharSequence dataLocation, CloseableIterable<? extends StructLike> deleteFile)
static java.util.Set<java.lang.Long>	toPositionSet(CloseableIterable<java.lang.Long> posDeletes)

Methods inherited from class java.lang.Object

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

Method Detail

filter

public static <T> CloseableIterable<T> filter(CloseableIterable<T> rows,
                                              java.util.function.Function<T,StructLike> rowToDeleteKey,
                                              StructLikeSet deleteSet)

filter

public static <T> CloseableIterable<T> filter(CloseableIterable<T> rows,
                                              java.util.function.Function<T,java.lang.Long> rowToPosition,
                                              java.util.Set<java.lang.Long> deleteSet)

toEqualitySet

public static StructLikeSet toEqualitySet(CloseableIterable<StructLike> eqDeletes,
                                          Types.StructType eqType)

toPositionSet

public static java.util.Set<java.lang.Long> toPositionSet(java.lang.CharSequence dataLocation,
                                                          CloseableIterable<? extends StructLike> deleteFile)

toPositionSet

public static <T extends StructLike> java.util.Set<java.lang.Long> toPositionSet(java.lang.CharSequence dataLocation,
                                                                                 java.util.List<CloseableIterable<T>> deleteFiles)

toPositionSet

public static java.util.Set<java.lang.Long> toPositionSet(CloseableIterable<java.lang.Long> posDeletes)

streamingFilter

public static <T> CloseableIterable<T> streamingFilter(CloseableIterable<T> rows,
                                                       java.util.function.Function<T,java.lang.Long> rowToPosition,
                                                       CloseableIterable<java.lang.Long> posDeletes)

deletePositions

public static CloseableIterable<java.lang.Long> deletePositions(java.lang.CharSequence dataLocation,
                                                                CloseableIterable<StructLike> deleteFile)

deletePositions

public static <T extends StructLike> CloseableIterable<java.lang.Long> deletePositions(java.lang.CharSequence dataLocation,
                                                                                       java.util.List<CloseableIterable<T>> deleteFiles)