csp
csp copied to clipboard
Point72
csp is a high performance reactive stream processing library, written in C++ and Python
Resolves: - #277 - #400 We basically have bi-directional maps from each adapter (subscribe/send) to the endpoints we have.
Explain the changes (and incorporate the comments) described in this PR of integrating pydantic support with csp: * Structs * Enums * Numpy array types https://github.com/Point72/csp/pull/428
It's used in the wikimedia example, and is useful for picking the right adapters during graph building
- Major chagne is to allow multiple consumers / consumer threads to service the same topic - Each consumer can now get assigned a subset of partitions for a topic....
…MWLockFree queue instead of individual mutex locked std::queue
In the current implementation, `csp_autogen` script always perform a full module import, which triggers execution of parent-level `__init__.py` files. These `__init__.py` files may import dependencies that are unavailable at build...
**Is your feature request related to a problem? Please describe.** much more efficient data representation than the current JSON offering **Describe the solution you'd like** Integration with Avro schemas for...
Cleanup and a few fixes to https://github.com/Point72/csp/pull/574, thanks @sim15 for the contribution!