Microsoft.Spark.Sql.Streaming 네임스페이스
중요
일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.
클래스
DataStreamReader |
DataStreamReader는 외부 스토리지 시스템(예: 파일 시스템, 키-값 저장소 등)에서 스트리밍 DataFrame 을 로드하는 기능을 제공합니다. |
DataStreamWriter |
DataStreamWriter는 외부 스토리지 시스템(예: 파일 시스템, 키-값 저장소 등)에 스트리밍 DataFrame 을 작성하는 기능을 제공합니다. |
StreamingQuery |
새 데이터가 도착할 때 백그라운드에서 지속적으로 실행되는 쿼리에 대한 핸들입니다. |
StreamingQueryException |
를 중지한 예외입니다 StreamingQuery. |
StreamingQueryManager |
의 모든 활성을 StreamingQuery 관리하는 클래스입니다 SparkSession. |
Trigger |
에서 결과를 생성해야 하는 빈도를 나타내는 데 사용되는 정책 StreamingQuery |
열거형
OutputMode |
스트리밍 DataFrame의 데이터를 스트리밍 싱크에 쓰는 방법을 지정하기 위한 출력 모드입니다. |
피드백
https://aka.ms/ContentUserFeedback
출시 예정: 2024년 내내 콘텐츠에 대한 피드백 메커니즘으로 GitHub 문제를 단계적으로 폐지하고 이를 새로운 피드백 시스템으로 바꿀 예정입니다. 자세한 내용은 다음을 참조하세요.다음에 대한 사용자 의견 제출 및 보기