Package org.apache.iceberg.deletes
Class Deletes
- java.lang.Object
-
- org.apache.iceberg.deletes.Deletes
-
public class Deletes extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods 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, PositionDeleteIndex 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>
PositionDeleteIndextoPositionIndex(java.lang.CharSequence dataLocation, java.util.List<CloseableIterable<T>> deleteFiles)
static PositionDeleteIndex
toPositionIndex(CloseableIterable<java.lang.Long> posDeletes)
-
-
-
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, PositionDeleteIndex deleteSet)
-
toEqualitySet
public static StructLikeSet toEqualitySet(CloseableIterable<StructLike> eqDeletes, Types.StructType eqType)
-
toPositionIndex
public static <T extends StructLike> PositionDeleteIndex toPositionIndex(java.lang.CharSequence dataLocation, java.util.List<CloseableIterable<T>> deleteFiles)
-
toPositionIndex
public static PositionDeleteIndex toPositionIndex(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)
-
-