StreamingQuery 클래스

정의

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

public sealed class StreamingQuery
type StreamingQuery = class
Public NotInheritable Class StreamingQuery
상속
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()

실행 중인 경우 이 쿼리의 실행을 중지합니다. 이 메서드는 실행을 수행하는 스레드가 중지될 때까지 차단합니다.

적용 대상