6.4.3 스트리밍 실행 관리

 

start 메서드는 스트리밍 실행의 핸들과 같은 역할을 하는 StreamingQuery 객체를 반환한다. 이 객체로 다음과 같이 스트리밍 실행을 관리할 수 있다. isActive 메서드로 스트리밍 실행 상태를 확인할 수 있으며, stop 메서드로 스트리밍 실행을 종료할 수 있다. awaitTermination 메서드는 스트리밍 실행이 종료될 때까지 애플리케이션을 종료하지 않도록 막는다. 예외가 발생했을 때 exception 메서드로 예외 정보를 살펴볼 수 있으며, id 필드로 실행 ID를 가져올 수도 있다.

또 SparkSession.streams로 제공되는 StreamingQueryManager 클래스로 여러 스트리밍의 실행 상황을 질의할 수 있다. SparkSession.streams.active 메서드는 현재 활성화된 StreamingQuery 객체의 배열을 반환한다. SparkSession.streams.get(id)로 특정 ID의 StreamingQuery 객체를 가져올 수 있다. SparkSession.streams.awaitAnyTermination은 실행 중인 여러 쿼리 중 어느 하나가 종료될 때까지 애플리케이션을 종료하지 않도록 막는다.