Package dev.vortex.api
Interface ScanOptions
@Immutable
public interface ScanOptions
Scan configuration passed to
DataSource.scan(ScanOptions).
All fields are optional. A call to of() returns a default that reads every row and column.
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic enumHow to interpret the row selection payload. -
Method Summary
Modifier and TypeMethodDescriptionstatic dev.vortex.api.ImmutableScanOptions.Builderbuilder()static ScanOptionsexcludeRows(long... rowIndices) Scan all rows except the given sorted ascending, unique row indices.static ScanOptionsexcludeRows(org.roaringbitmap.longlong.Roaring64NavigableMap rowSelection) Scan all rows except the rows in the given Roaring bitmap.filter()Filter expression applied before returning rows.static ScanOptionsincludeRows(long... rowIndices) Scan only the rows at the given sorted ascending, unique row indices.static ScanOptionsincludeRows(org.roaringbitmap.longlong.Roaring64NavigableMap rowSelection) Scan only the rows in the given Roaring bitmap.limit()Maximum row count to return.static ScanOptionsof()default booleanordered()Iftrue, the scan preserves the original row order across partitions.Projection expression.Inclusive start of the row range to read.Exclusive end of the row range to read.Optional<long[]>Sorted ascending, unique row indices that should be included in (or excluded from) the scan, depending onselectionMode().default ScanOptions.SelectionModeMeaning of the row selection payload.Optional<byte[]>Portable serializedRoaring64NavigableMaprow selection.default void
-
Method Details
-
projection
Optional<Expression> projection()Projection expression. If empty, all columns are returned. -
filter
Optional<Expression> filter()Filter expression applied before returning rows. -
rowRangeBegin
OptionalLong rowRangeBegin()Inclusive start of the row range to read. -
rowRangeEnd
OptionalLong rowRangeEnd()Exclusive end of the row range to read. -
selectionIndices
Optional<long[]> selectionIndices()Sorted ascending, unique row indices that should be included in (or excluded from) the scan, depending onselectionMode(). -
selectionRoaringBitmap
Optional<byte[]> selectionRoaringBitmap()Portable serializedRoaring64NavigableMaprow selection. -
selectionMode
Meaning of the row selection payload. -
limit
OptionalLong limit()Maximum row count to return. Absent means "no limit". -
ordered
@Default default boolean ordered()Iftrue, the scan preserves the original row order across partitions. -
validateSelectionPayload
@Check default void validateSelectionPayload() -
of
-
builder
static dev.vortex.api.ImmutableScanOptions.Builder builder() -
includeRows
Scan only the rows at the given sorted ascending, unique row indices. -
excludeRows
Scan all rows except the given sorted ascending, unique row indices.
-