structured-streaming

Apache Spark SQL 엔진을 기반으로 구축된 확장 가능하고 결함 허용이 가능한 스트림 처리 엔진이다. 정적 데이터에 대한 배치 계산과 동일한 방식으로 스트리밍 계산을 표현할 수 있게 하여 개발 복잡도를 낮춘다.