Kaskada query builder and local execution engine.
Project description
Kaskada Timestreams
Kaskada's timestreams
library makes it easy to work with structured event-based data.
Define temporal queries on event-based data loaded from Python, using Pandas or PyArrow and push new data in as it occurs.
Or, execute the queries directly on events in your data lake and/or as they arrive on a stream.
With Kaskada you can unleash the value of real-time, temporal queries without the complexity of "big" infrastructure components like a distributed stream or stream processing system.
Under the hood, timestreams
is an efficient temporal query engine built in Rust.
It is built on Apache Arrow, using the same columnar execution strategy that makes ...
Install Python
Use pyenv
and install at least 3.8
(most development occurs under 3.11
).
If multiple versions are installed, nox
will test against each of them.
Building and Testing
To build this package, first install maturin
:
poetry shell
poetry install --no-root
maturin develop
pytest
Alternatively, install nox and run the tests inside an isolated environment:
nox
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distributions
Hashes for kaskada-0.6.0a3-cp38-abi3-win_amd64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | b62bcaaf0b5887a5f51fd71c263df1a3a82afe1a9ef5b53f4bc31aca15e6eba2 |
|
MD5 | 39e752dae3c3699b74da3a216824e583 |
|
BLAKE2b-256 | be2ece0008b2471b2150af92d3ed6ea17ecb1da4c48b0824fd53b959aedaf0f1 |
Hashes for kaskada-0.6.0a3-cp38-abi3-manylinux_2_28_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6354ee8c204edb586c944c6da346b8accb7bdd099d58accd2f9ccf1acc8d5dd8 |
|
MD5 | a59a07677f53dc07665bbc5a6b3638e8 |
|
BLAKE2b-256 | 1b7df081a664a779cb1a395e1cdaee16e9fc657cf14c86611006a9a6fe8d0f38 |
Hashes for kaskada-0.6.0a3-cp38-abi3-macosx_11_0_x86_64.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | dc9e37cd9e20625b3cf83557fbe298c10d5096f6b6e23e89255e49ad7e9d6310 |
|
MD5 | 0ad69dcc7b9f31851b944e04aa31bfa9 |
|
BLAKE2b-256 | a46d2ca315ec66ae6ce50fdebfdd856bfc3192805e62611cba1f5ebc3f329abf |
Hashes for kaskada-0.6.0a3-cp38-abi3-macosx_11_0_x86_64.macosx_11_0_arm64.macosx_11_0_universal2.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | aa21d082b9b6b4295cafd04301f5d3ce64240f70d416d8f1f02540210d98e125 |
|
MD5 | 13db2b90d1a61ce3eae17fb354cf4138 |
|
BLAKE2b-256 | 290391d5db36e675ec2436664e9fc425596a5230cf8de925e6df85a94bed7879 |