스트리밍 쿼리에 대한 트리거를 설정합니다. 설정하지 않으면 쿼리는 가능한 한 processingTime='0 seconds'빨리 실행됩니다. 한 번에 하나의 트리거 매개 변수만 설정할 수 있습니다.
자세한 내용은 구조적 스트리밍 트리거 간격 구성을 참조하세요.
문법
trigger(*, processingTime=None, once=None, continuous=None, availableNow=None, realTime=None)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
processingTime |
str, 선택 사항 | 처리 시간 간격 문자열(예: '5 seconds', '1 minute')입니다. 처리 시간에 따라 주기적으로 마이크로배치 쿼리를 실행합니다. |
once |
bool, 선택 사항 | 이 경우 True하나의 데이터 일괄 처리만 처리하면 쿼리가 종료됩니다. |
continuous |
str, 선택 사항 | 시간 간격 문자열(예: '5 seconds')입니다. 지정된 검사점 간격으로 연속 쿼리를 실행합니다. |
availableNow |
bool, 선택 사항 | 사용 가능한 모든 데이터를 여러 일괄 처리로 처리하면 True쿼리가 종료됩니다. |
realTime |
str, 선택 사항 | 일괄 처리 기간 문자열(예: '5 seconds')입니다. 지정된 기간에 일괄 처리를 사용하여 실시간 모드 쿼리를 실행합니다. |
Returns
DataStreamWriter
예제
df = spark.readStream.format("rate").load()
5초마다 실행을 트리거합니다.
df.writeStream.trigger(processingTime='5 seconds')
# <...streaming.readwriter.DataStreamWriter object ...>
5초마다 연속 실행을 트리거합니다.
df.writeStream.trigger(continuous='5 seconds')
# <...streaming.readwriter.DataStreamWriter object ...>
사용 가능한 모든 데이터를 여러 일괄 처리로 처리합니다.
df.writeStream.trigger(availableNow=True)
# <...streaming.readwriter.DataStreamWriter object ...>
5초마다 실시간 실행을 트리거합니다.
df.writeStream.trigger(realTime='5 seconds')
# <...streaming.readwriter.DataStreamWriter object ...>