a0bc1371dd
* Adding "raw message" column to the result return by CHECK STREAM query * Update way results of CHECK STREAM are built * Adapting CHECK STREAM integration tests (Pulsar/Kafka) to run with new result structure * Adding new tests covering the check stream functionality * Uppercase constants in stream tests * Reformat f-strings |
||
---|---|---|
.. | ||
c_transformations.cpp | ||
CMakeLists.txt | ||
common_transform.py | ||
kafka_transform.py | ||
pulsar_transform.py |