API потоковой обработки как непрерывных/триггерных DataFrame-трансляций: source → transform → sink, с checkpoint для exactly-once/at-least-once семантики sink'ов.
Разбор
- micro-batch по умолчанию; continuous processing ограничен.
- Watermark для late data в window aggregations.
- Checkpoint location обязателен для production.
- Не заменяет Flink для сложного low-latency event processing всегда.
Итог
Structured Streaming = тот же DataFrame API + триггеры/checkpoint для потока.