다음을 통해 공유

read_state_metadata 테이블 반환 함수

  • 아티클

적용 대상: 예로 표시된 확인 Databricks SQL 예로 표시된 확인 Databricks Runtime 14.3 이상

스트리밍 쿼리 상태의 메타데이터를 나타내는 행이 있는 테이블을 반환합니다.

스트리밍 쿼리 상태 저장 연산자의 메타데이터를 읽기 위한 테이블 반환 함수입니다. 일괄 처리 쿼리로만 실행할 수 있습니다.

구문

read_state_metadata(path)

인수

이 함수에는 옵션 키에 대한 명명된 매개 변수 호출 이 필요합니다.

  • pathSTRING: 스트리밍 쿼리 검사점 위치의 경로가 있는 리터럴입니다.

반품

상태 메타데이터 테이블에는 다음 스키마가 있습니다. 모든 열은 NULL이 아닙니다.

  • operatorId INT NOT NULL

    상태 저장 스트리밍 연산자의 정수 ID입니다.

  • operatorName STRING NOT NULL

    상태 저장 스트리밍 연산자의 이름입니다.

  • stateStoreName STRING NOT NULL

    연산자 상태 저장소의 이름입니다.

  • numPartitions INT NOT NULL

    상태 저장소의 파티션 수입니다.

  • minBatchId BIGINT NOT NULL

    쿼리 상태에 사용할 수 있는 최소 배치 ID입니다. 검사점을 사용하는 스트리밍 쿼리가 실행 중이면 정리가 실행되므로 값이 잘못될 수 있습니다.

  • maxBatchId BIGINT NOT NULL

    쿼리 상태에 사용할 수 있는 최대 배치 ID입니다. 쿼리가 추가 일괄 처리를 커밋하므로 검사점을 사용하는 스트리밍 쿼리가 실행 중인 경우 값이 잘못될 수 있습니다.

예제

- Read state metadata from the checkpoint
> SELECT * FROM read_state_metadata('/checkpoint/path');