Streaming queries

Practical aspects of working with streaming queries:

• Using local and external topics
• Typical patterns — minimal examples for a quick start
• Writing to tables — how streaming queries allow writing data to YDB tables in real time.
• Data enrichment — ways to enrich data in the stream using reference data.
• Data formats for reading/writing topics — supported data formats when working with topics, examples of their use.
• Data delivery guarantees — level of guarantees, observed anomalies in window aggregation, and recommendations.
• Checkpoints — a mechanism for saving the state of stream processing to ensure fault tolerance and recovery capability.
• Watermarks — a mechanism for tracking time progress in a data stream.

See also

• Recipes for working with streaming queries
• Description of streaming queries