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, 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)
-
-
-
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)
-
-