Generated banner for Vaex
Generated logo for Vaex

Vaex

K-DenseCommunityCreated by K-Dense Inc.

  • Skill
  • Tool integration
  • Data and AI
  • MIT
  • Low risk

From the author

Processes large tabular scientific datasets with Vaex expressions, filtered views, streamed statistics, binned visualizations, and file conversion. Use for larger-than-RAM HDF5, Arrow, CSV, or Parquet analysis, virtual feature engineering, or Vaex ML preprocessing; distinguishes these operations from estimators and conversions that materialize data.
— the description by K-Dense Inc.

From the skill’s files

Taken from the skill’s own files (its description, section headings and stated usage). Not an AutoGineer summary, and not written by the author as one.

Processes large tabular scientific datasets with Vaex expressions, filtered views, streamed statistics, binned visualizations, and file conversion. Use for larger-than-RAM HDF5, Arrow, CSV, or Parquet analysis, virtual feature engineering, or Vaex ML preprocessing; distinguishes these operations from estimators and conversions that materialize data. Use Vaex for columnar analysis on a single machine when data exceeds RAM, especially repeated reductions and histograms over local Vaex HDF5 or Arrow files. Expressions and virtual columns defer computation; reductions normally execute immediately. Out-of-core storage does not make every operation memory bounded: sorting, joins, large group dictionaries, materialization, and many estimator fits need substantial RAM.

What it does

  • When to use
  • Installation and verified scope
  • Workflow
  • Small executable example
  • Reference map
  • Failure checks

When to use it

  • Use for larger-than-RAM HDF5, Arrow, CSV, or Parquet analysis, virtual feature engineering, or Vaex ML preprocessing; distinguishes these operations from estimators and conversions that materialize…
  • Use Vaex for columnar analysis on a single machine when data exceeds RAM, especially repeated reductions and histograms over local Vaex HDF5 or Arrow files.
  • Expressions and virtual columns defer computation; reductions normally execute immediately.
  • Out-of-core storage does not make every operation memory bounded: sorting, joins, large group dictionaries, materialization, and many estimator fits need substantial RAM.

Advantages

The skill’s files do not state this.

Usage examples

The skill’s files do not state this.

Install

  1. Download the skill as a ZIP:

    https://autogineer.com/agent-skills/k-dense-ai/vaex/download
  2. Unzip it into the cross-client skills folder of your project:

    mkdir -p .agents/skills && unzip vaex.zip -d .agents/skills

Documentation by K-Dense Inc.

Vaex

When to use

Use Vaex for columnar analysis on a single machine when data exceeds RAM, especially repeated reductions and histograms over local Vaex HDF5 or Arrow files. Expressions and virtual columns defer computation; reductions normally execute immediately. Out-of-core storage does not make every operation memory bounded: sorting, joins, large group dictionaries, materialization, and many estimator fits need substantial RAM.

Installation and verified scope

Use a separate environment; the repository's default Python is newer than this release supports:

uv venv --python 3.12 .venv-vaex
uv pip install --python .venv-vaex/bin/python "vaex-core==4.19.0" "vaex-hdf5==0.15.0" "vaex-viz==0.6.0"
# Optional ML (also installs its declared estimator dependencies):
uv pip install --python .venv-vaex/bin/python "vaex-ml==0.19.0"

On Windows use .venv-vaex\Scripts\python.exe as the interpreter path. The vaex 4.19.0 metapackage installs more integrations; it is not needed for the core workflow. Core 4.19.0 declares Python >=3.9,<3.13, pandas <3, Dask <2024.9, and NumPy <3. Do not upgrade these constraints independently. Arrow support is in core; FITS needs vaex-astro. Compatible binary wheels determine platform availability; compiling the optional annoy dependency requires a C++ toolchain, not just Python headers.

Native checks used Python 3.12, core 4.19.0, HDF5 0.15.0, viz 0.6.0, ML 0.19.0, NumPy 2.5.3, pandas 2.3.3, PyArrow 25.0.1 and Matplotlib 3.11.2 on macOS ARM. See review and verification for evidence and optional-integration limits. These are correctness checks on small synthetic inputs, not performance benchmarks.

Workflow

  1. Establish row identity, units, schema, missing-value codes, and expected counts. Inspect CSV raw headers before parsers rename duplicates; supply explicit types for IDs and late-appearing values. Keep dates, time zones, and sampling cadence explicit.

  2. Open files with vaex.open. HDF5 must use a compatible table layout; arbitrary HDF5 scientific arrays are not automatically a Vaex table. CSV opening performs indexing/schema work; Parquet must decode compressed data. Neither is an instant, zero-memory operation.

  3. Select needed columns and use expressions for derived values. A virtual column avoids a full stored array but still needs expression metadata and evaluation buffers.

  4. Record filters/selections and missingness before reductions. Batch independent statistics with delay=True, then df.execute() and each promise's .get().

  5. Validate counts, units, join cardinality, and numerical results against a small independently computed subset. Binned or approximate summaries need explicit limits/resolution.

  6. Plot aggregated grids or a bounded sample. A count heatmap and a mean heatmap answer different questions; show coverage and avoid hiding rare/extreme observations silently.

  7. Export directly in chunks; exporting evaluates virtual columns without needing materialize() first. Reopen and check counts/schema/values before replacing source data.

Small executable example

Run in a writable working directory; output names must not refer to existing data.

from pathlib import Path
import numpy as np
import vaex

out = Path('vaex-example.hdf5')
if out.exists():
    raise FileExistsError(out)
df = vaex.from_arrays(
    x=np.arange(1., 7.), y=np.arange(6.) ** 2,
    category=np.array(['A', 'B', 'A', 'B', 'A', 'B']),
)
df['energy'] = df.x ** 2 + df.y
selected = df[df.x >= 3]
mean_task = selected.energy.mean(delay=True)
count_task = selected.count(delay=True)
selected.execute()
assert count_task.get() == 4
assert np.isclose(mean_task.get(), 35.0)
summary = df.groupby('category', agg={
    'rows': vaex.agg.count(), 'energy_sum': vaex.agg.sum('energy'),
})
assert int(summary.rows.sum()) == len(df)
df.export_hdf5(str(out), chunk_size=2)
reopened = vaex.open(str(out))
assert reopened.get_column_names() == df.get_column_names()
assert np.allclose(reopened.energy.to_numpy(), df.energy.to_numpy())

For a large real input, replace the in-memory fixture with vaex.open('input.hdf5'). The small .to_numpy() comparison above is a fixture check; do not apply it to a whole larger-than-RAM dataset. Compare sampled rows and streamed summaries instead.

Reference map

  • Core DataFrames: loaders, expression/array distinctions, inspection and schema.

  • Data processing: filtering, missingness, strings/dates, grouped statistics and joins.

  • Performance: delayed/async execution, caching, buffers, materialization and profiling.

  • Visualization: supported df.viz methods, grid geometry, finite plotting limits and widgets.

  • Machine learning: train-only fitting, native transformers, estimator memory and state transfer.

  • I/O: chunked CSV conversion, HDF5/Arrow/Parquet round trips and remote boundaries.

Failure checks

  • df.x.mean() returns a computed result; it is not a lazy expression.

  • Use df.percentile_approx('x', percentage=50) for approximate percentiles; Expression.quantile is not a core 4.19.0 API.

  • Use explicit vaex.agg objects to name grouped outputs. Do not assume pandas dictionary aggregation or arbitrary group callbacks have the same contract.

  • join defaults to left; declare how, validate keys, and extract filtered inputs when the filter must define join membership. Joins accept one key expression per side.

  • .values, .to_numpy(), unchunked .to_pandas_df(), .materialize(), and ordinary sklearn Predictor.fit() can allocate full arrays.

  • State files carry transformations and potentially serialized executable objects; load only trusted artifacts. They do not carry the original dataset or prove its provenance.

Citing Scientific Agent Skills

This skill is part of Scientific Agent Skills by K-Dense. If it materially contributed to a manuscript, report, presentation, or code release, add the paper to the references or software section and tell the user you did so:

Kassis, T., Agarwal, V., He, Y., Patel, D., & Brueckner, A. M. (2026). Scientific Agent Skills: A Library of Procedural Knowledge for Research Agents. arXiv:2609.00065. https://doi.org/10.48550/arXiv.2609.00065

Always cite the current version. The DOI and https://arxiv.org/abs/2609.00065 resolve to the latest arXiv version, so never append a version suffix such as v1. When network access is available, fetch https://arxiv.org/abs/2609.00065 (or http://export.arxiv.org/api/query?id_list=2609.00065) before writing the reference and take the author list, year, and version from that record. If the record lists a journal reference or publisher DOI, cite the published version instead.

Files

references/performance.md

Performance and memory

Targets core 4.19.0. See caching, configuration, and released executor/cache source.

Batch independent reductions

import asyncio
import numpy as np
import vaex

df = vaex.from_arrays(x=np.arange(10.), y=np.arange(10.) ** 2)
df['derived'] = df.x ** 2 + df.y
pending = [df.derived.mean(delay=True), df.x.std(delay=True), df.y.sum(delay=True)]
df.execute()
values = [task.get().item() for task in pending]
assert np.allclose(values, [57., np.std(np.arange(10.)), 285.])

async def compute(frame):
    mean = frame.x.mean(delay=True)
    count = frame.count(delay=True)
    await frame.execute_async()
    return mean.get().item(), count.get().item()

assert asyncio.run(compute(df)) == (4.5, 10)

In a notebook with a running event loop, use await compute(df) instead of asyncio.run. Defining an expression or virtual column defers per-row evaluation; ordinary reductions execute now. Promises must be executed before .get(). There is no public vaex.execute([tasks]) collection API. Batching compatible tasks can share scans, but "one pass" is not universal: limits, means, variance or dependant tasks can need preliminary work. Measure actual data passes and timing on the target workload.

Memory boundaries

OperationAllocation to plan for
HDF5/Arrow openMetadata, handles, mapped/address space and accessed pages
Virtual columnsExpression metadata and per-chunk temporary arrays
Filters/selectionsBoolean masks and selection/cache metadata
Reductions/gridsChunk buffers and grid accumulators; grid size grows with dimensions
Groupby/unique/join/sortCardinality dictionaries, output tables and/or row index arrays
.values, .to_numpy(), unchunked pandas conversionRequested full arrays
.materialize()Full selected virtual columns in memory
sklearn Predictor.fitFull feature matrix and target, plus estimator allocations

df.byte_size() describes data bytes, not resident memory or a process limit. df.is_local() tells whether the frame is local rather than a remote server frame; it accepts no column argument and does not indicate virtual columns or memory mapping. Use df.virtual_columns to inspect derived definitions. df.copy() is shallow.

assert 'derived' in df.virtual_columns
assert df.is_local()
materialized = df.materialize('derived')  # small fixture only
assert 'derived' not in materialized.virtual_columns
assert np.allclose(materialized.derived.to_numpy(), 2 * np.arange(10.) ** 2)
rows = 0
for start, stop, chunk in df[['x', 'derived']].to_pandas_df(chunk_size=3):
    assert len(chunk) == stop - start
    rows += len(chunk)
assert rows == 10

Export already evaluates virtual columns in chunks. Materializing first is not a fix for an out-of-memory export. Reduce selected columns/chunk size, bound group cardinality, check disk capacity and profile the actual operation instead. Avoid collecting all pandas chunks into a list, which reconstructs the full allocation.

Explicit caching and timing

vaex.cache starts disabled unless configured. A repeated mean is not guaranteed to be cached. Optional cachetools supplies the bounded in-memory cache below:

import time
import vaex.cache

with vaex.cache.memory(maxsize='8MiB', clear=True):
    first = df.x.mean()
    second = df.x.mean()
    assert first == second
with vaex.cache.off():
    start = time.perf_counter()
    result = df.y.sum()
    elapsed = time.perf_counter() - start
assert result == 285
print({'elapsed_seconds': elapsed, 'column_bytes': df.byte_size()})

Cache budget is not a total-RSS cap. Cached results, operating-system file cache and warm compiled kernels can change timing; report warm/cold conditions, package versions, row/column counts, dtype, hardware, storage and workload. No universal billion-rows-per-second claim applies to arbitrary expressions or files. Use Python profiling tools or timing; with vaex.profiler(): is not a supported context manager.

Set VAEX_NUM_THREADS in the process environment before starting Python for repeatable thread limits. Avoid oversubscription with BLAS/Numba/estimator threads. More threads can increase per-worker buffers and do not guarantee faster I/O.

Other execution engines

Core 4.19.0 does not have to_dask_dataframe(). Its documented Dask integration is to_dask_array() for numerical arrays; that alone does not provision a distributed cluster. Core pins Dask <2024.9, so current standalone Dask recommendations cannot be transplanted into this environment without compatibility work. Dask guide.

For custom functions, prefer built-in expression operations. df.apply(function, arguments=[...], vectorize=True) calls the function on array chunks and can allocate chunk outputs; vectorize=False has different, row-function behavior. Verify types, nulls and independent numerical results. JIT compilation does not create a nonexistent Expression.custom_agg API, and compilation time is separate from steady-state timing.

Requirements and compatibility

Works with: Claude Code, Claude apps, OpenAI Codex, GitHub Copilot, Cursor, Gemini CLI, Kiro, OpenCode, Goose, Amp, Roo Code, JetBrains Junie, Factory Droid, Devin (ex-Windsurf), Mistral Vibe, OpenHands, Letta

“Works with” means the tool reads the open Agent Skills format; a skill written for one tool may use features others lack.

Needs: Declares allowed tools, Needs network access, Needs Python

The author says: Requires Python 3.9-3.12 for vaex-core 4.19.0; tested on Python 3.12. Install vaex-core plus vaex-hdf5, vaex-viz, or vaex-ml as needed. Package installation and remote data need network access; local workflows need no credentials.

Security

What our scanner noticed· Low risk

  • Instructions that use the network

A static scan is not a guarantee. Skills are third-party content: review a skill before you let an agent use it.

Attribution and licence

Created by
K-Dense Inc.
Publisher
K-Dense (Community)
Source
K-Dense-AI/scientific-agent-skills · skills/vaex · commit a25cf9e
Licence
MIT License (redistribution allowed)
  • LICENSE (added by AutoGineer from LICENSE.md)
  • ATTRIBUTION.md (written by AutoGineer)
Synced

AutoGineer is not affiliated with or endorsed by K-Dense Inc. or K-Dense.

Download ZIP

The ZIP holds the skill’s files, its licence files and an ATTRIBUTION.md. Download vaex.zip