“Your instrument outgrew the workstation, and the queue outgrew your patience”
Instrument data. Answers in minutes.
Interactive reduction of large instrument files without queueing a cluster job
- The raw data no longer fits on a workstation, and the HPC queue takes days.
- My pipeline is a notebook only I can run, and I cannot reproduce last year's result.
- Nobody can say which code and which inputs produced this figure.
- Interactive reduction of large instrument files without queueing a cluster job
- Re-runnable, citable analysis: same inputs give the same outputs, with a hash per step
- Develop at the bench, scale up without a rewrite, no data egress
From today to the first result.
a workstation, a notebook and an HPC queue
The raw data no longer fits on a workstation, the HPC queue takes days, and nobody can say which code and inputs produced a figure.
100 million rows on two machines summed in 14.7 s, 1 billion rows in 32.1 ms on one notebook — and a signed workflow gives the same result from the same inputs.
Run one reduction step on a notebook beside the HPC job and compare the results.
one reductionOne query over two machines. Step by step.
100 million rows are split across two machines by key and answered by one query.
- RandomDataProviderGenerators.Random
- Cluster NodeCluster.Node
- Command Control NodeWorkflow.Streaming.CommandControlNode
- CLI ProcessorETL.CLIProcessor
src → Generators.Random
fab → Cluster.Node
q → Workflow.Streaming.CommandControlNode
out → ETL.CLIProcessor- RandomDataProviderGenerates 100,000,000 seeded rows.
- Cluster NodeSplits the rows across master and peer by key hash.
- Command Control NodeRuns SELECT SUM(v), COUNT(*) on the cluster.
- CLI ProcessorPrints the result.
A real workflow from our end-to-end test suite; the designer view is illustrated.
What you get. From the first pilot.
Interactive reduction of large instrument files without queueing a cluster job
Re-runnable, citable analysis: same inputs give the same outputs, with a hash per step
Develop at the bench, scale up without a rewrite, no data egress
Why your tools fall short.
Spark/Dask need a cluster and ops skills most labs lack
Snakemake/Nextflow orchestrate jobs but do not make the compute itself fast or deterministic
Cloud analytics are blocked by data-protection and egress cost
- Data volumes outgrowing workstations
- Reproducibility expectations from funders and journals
- Data-protection limits on moving data
- Idle expensive instruments waiting on analysis
Your pilot. Three steps.
Your data shape
Tell us what data you have, where it lives and what the result must be.
A scoped pilot
On your data and your hardware, with the success measure written down first.
A clear decision
You see the result against that measure — and keep every workflow and record.
Related roles in Research & geodata.
Bring us your hardest data problem. Let's solve it together.
A short pilot on your data and your hardware. We agree on what success looks like before we start.