WaitForTableState 프로세서
WaitForTableState 프로세서
Openflow의 WaitForTableState 프로세서는 테이블 상태가 허용된 상태와 같아질 때까지 FlowFile을 차단하는 데 사용합니다. 이 문서에서 프로세서의 번들, 설명, 속성, 관계 등을 확인할 수 있습니다.
출처: Snowflake 문서
본문
번들 (Bundle)
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명 (Description)
해당 테이블 상태가 허용된 상태와 같지 않을 때까지 들어오는 FlowFile을 차단합니다. 차단된 FlowFile은 업스트림 큐에 남아 있습니다. 테이블이 종료 상태(terminated state)이거나 상태에서 테이블이 제거되면 모든 FlowFile이 failure 관계로 라우팅됩니다.
태그 (Tags)
cdc, event, jdbc, mysql, postgresql, sql
입력 요구사항 (Input Requirement)
REQUIRED
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| 속성 (Property) | 설명 (Description) |
|---|---|
| Accepted State | 주어진 SourceTableFQN에 대해 해당 상태가 Accepted State와 같아질 때까지 FlowFile을 차단합니다. |
| Table State Service | 복제된 각 테이블의 상태를 관리합니다. |
관계 (Relationships)
| 이름 (Name) | 설명 (Description) |
|---|---|
| failure | 종료 상태에 있는 테이블의 FlowFile이 이 관계로 라우팅됩니다. |
| success | 주어진 조건을 충족하는 FlowFile이 이 관계로 라우팅됩니다. |