Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 2 additions & 4 deletions vortex-array/src/aggregate_fn/fns/min_max/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -417,10 +417,8 @@ impl AggregateFnVTable for MinMax {
Canonical::Decimal(d) => accumulate_decimal(partial, d, ctx),
Canonical::Extension(e) => accumulate_extension(partial, e, ctx),
Canonical::Null(_) => Ok(()),
Canonical::Union(_) => {
todo!("TODO(connor)[Union]: implement min_max for Union arrays")
}
Canonical::Struct(_)
Canonical::Union(_)
| Canonical::Struct(_)
Comment on lines +420 to +421
| Canonical::List(_)
| Canonical::Map(_)
| Canonical::FixedSizeList(_)
Expand Down
6 changes: 4 additions & 2 deletions vortex-bench/sql/vortex/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,14 +4,16 @@ A small suite of microbenchmark queries targeting Vortex-specific scan paths, ru
**every PR commit** (unlike the label-gated suites) with a high iteration count, so it is
the most sensitive — and most frequently seen — benchmark comment.

[`init.sql`](./init.sql) generates a 25M-row two-column table; the numbered queries each
pin down one scan behavior:
[`init.sql`](./init.sql) generates a 2.5B-row three-column table (`id`, `col`, `col2`); the
numbered queries each pin down one scan behavior:

- [`0_sum-with-filter.sql`](./0_sum-with-filter.sql): a filtered aggregation that forces a
linear scan today; once statistics are propagated to arrays it should use zone maps
instead of decoding every row.
- [`1_sum.sql`](./1_sum.sql): an unfiltered aggregation that should eventually be answered
from footer statistics without decoding data.
- [`2_sum-range.sql`](./2_sum-range.sql): a range filter on `id` that should prune most
zone maps and only fully decode the two zones that overlap the bounds.
Comment on lines +15 to +16

## CI variant

Expand Down
4 changes: 3 additions & 1 deletion vortex-ffi/src/session.rs
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,9 @@ pub unsafe extern "C-unwind" fn vx_session_new() -> *mut vx_session {
vx_session_new_with(|session| session)
}

/// Clone a vx_session
/// Clone a Vortex session, returning an owned copy.
///
/// The caller is responsible for freeing the session with [`vx_session_free`].
Comment on lines +37 to +39
#[unsafe(no_mangle)]
pub unsafe extern "C-unwind" fn vx_session_clone(session: *const vx_session) -> *mut vx_session {
let session = vx_session::as_ref(session);
Expand Down
4 changes: 2 additions & 2 deletions vortex-python/python/vortex/_lib/file.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ from typing_extensions import override

from vortex.type_aliases import IntoProjection

from . import CosStore, HfStore
from . import CosStore, GoosefsStore, HfStore
from .arrays import Array
from .dataset import VortexDataset
from .dtype import DType
Expand Down Expand Up @@ -61,6 +61,6 @@ class VortexFile:
def open(
path: str,
*,
store: ObjectStore | CosStore | HfStore | None = None,
store: ObjectStore | CosStore | GoosefsStore | HfStore | None = None,
without_segment_cache: bool = False,
) -> VortexFile: ...
3 changes: 2 additions & 1 deletion vortex-python/python/vortex/file.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
AzureStore,
CosStore,
GCSStore,
GoosefsStore,
HfStore,
HTTPStore,
LocalStore,
Expand All @@ -34,7 +35,7 @@
def open(
path: str,
*,
store: AzureStore | CosStore | GCSStore | HfStore | HTTPStore | LocalStore | MemoryStore | S3Store | None = None,
store: AzureStore | CosStore | GCSStore | GoosefsStore | HfStore | HTTPStore | LocalStore | MemoryStore | S3Store | None = None,
without_segment_cache: bool = False,
) -> VortexFile:
"""
Expand Down
Loading