다음을 통해 공유


Microsoft.Spark.Sql.Streaming 네임스페이스

클래스

DataStreamReader

DataStreamReader는 외부 스토리지 시스템(예: 파일 시스템, 키-값 저장소 등)에서 스트리밍 DataFrame 을 로드하는 기능을 제공합니다.

DataStreamWriter

DataStreamWriter는 외부 스토리지 시스템(예: 파일 시스템, 키-값 저장소 등)에 스트리밍 DataFrame 을 작성하는 기능을 제공합니다.

StreamingQuery

새 데이터가 도착할 때 백그라운드에서 지속적으로 실행되는 쿼리에 대한 핸들입니다.

StreamingQueryException

를 중지한 예외입니다 StreamingQuery.

StreamingQueryManager

의 모든 활성을 StreamingQuery 관리하는 클래스입니다 SparkSession.

Trigger

에서 결과를 생성해야 하는 빈도를 나타내는 데 사용되는 정책 StreamingQuery

열거형

OutputMode

스트리밍 DataFrame의 데이터를 스트리밍 싱크에 쓰는 방법을 지정하기 위한 출력 모드입니다.