StreamingQuery 클래스

정의

중요

일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.

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

public sealed class StreamingQuery

type StreamingQuery = class

Public NotInheritable Class StreamingQuery

Id	검사점 데이터에서 다시 시작하는 동안 유지되는 이 쿼리의 고유 ID를 반환합니다. 즉, 이 ID는 쿼리가 처음으로 시작될 때 생성되며 검사점 데이터에서 다시 시작될 때마다 동일합니다. 또한 RunId도 참조하세요.
Name	쿼리의 사용자 지정 이름을 반환하거나 지정하지 않으면 null을 반환합니다.
RunId	이 쿼리 실행의 고유 ID를 반환합니다. 즉, 쿼리를 시작/다시 시작할 때마다 고유한 runId가 생성됩니다. 따라서 쿼리가 검사점에서 다시 시작될 때마다 동일 Id 하지만 서로 다릅니다 RunId.

AwaitTermination()	Stop() 또는 예외에 의해 이 쿼리의 종료를 기다립니다.
AwaitTermination(Int64)	이 쿼리가 시간 제한(밀리초) 내에 종료되면 true를 반환합니다.
Exception()	StreamingQueryException 예외에 의해 쿼리가 종료된 경우 이고, 그렇지 않으면 null입니다.
Explain(Boolean)	디버깅을 위해 실제 계획을 콘솔에 인쇄합니다.
IsActive()	이 쿼리가 적극적으로 실행 중인 경우 true를 반환합니다.
ProcessAllAvailable()	원본에서 사용 가능한 모든 데이터가 처리되고 싱크에 커밋될 때까지 차단합니다. 이 메서드는 테스트용입니다. 데이터가 지속적으로 도착하는 경우 이 메서드는 영원히 차단할 수 있습니다. 또한 이 메서드는 호출 전에 데이터에 동기적으로 추가된 데이터가 될 때까지만 차단되도록 `org.apache.spark.sql.execution.streaming.Source` 보장됩니다. (즉, `getOffset` 추가를 즉시 반영해야 합니다).
Stop()	실행 중인 경우 이 쿼리의 실행을 중지합니다. 이 메서드는 실행을 수행하는 스레드가 중지될 때까지 차단합니다.