UpdateTableState 프로세서
UpdateTableState 프로세서
Openflow의 UpdateTableState 프로세서는 Table State Service에서 테이블 상태를 업데이트하는 데 사용합니다. 이 문서에서 프로세서의 번들, 설명, 속성, 관계 등을 확인할 수 있습니다.
출처: Snowflake 문서
본문
번들 (Bundle)
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명 (Description)
Table State Service에서 테이블의 상태를 업데이트합니다.
태그 (Tags)
snowflake, state, table
입력 요구사항 (Input Requirement)
REQUIRED
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| 속성 (Property) | 설명 (Description) |
|---|---|
| CDC Schema Registry | 테이블의 상태가 제거되면 테이블도 지정된 CDC Schema Registry에서 제거됩니다. |
| Desired State | 테이블의 원하는 상태입니다. |
| Overwrite Existing | 테이블의 기존 상태를 덮어쓸지 여부입니다. false이면 상태가 현재 알려지지 않은 경우에만 상태가 업데이트됩니다. |
| Schema Name | 테이블의 스키마 이름입니다. |
| Table Name | 테이블의 이름입니다. |
| Table State Service | 업데이트할 Table State Service입니다. |
관계 (Relationships)
| 이름 (Name) | 설명 (Description) |
|---|---|
| comms failure | Table State Service와의 통신 실패로 테이블 상태를 업데이트할 수 없으면 FlowFile이 이 관계로 라우팅됩니다. |
| state exists | 테이블의 상태가 이미 알려져 있고 Overwrite Existing 속성이 false로 설정되어 테이블 상태가 업데이트되지 않으면 FlowFile이 이 관계로 라우팅됩니다. |
| success | 테이블 상태가 업데이트된 후 FlowFile이 이 관계로 라우팅됩니다. |
기록하는 속성 (Writes attributes)
| 이름 (Name) | 설명 (Description) |
|---|---|
| table.state | Table State Service를 업데이트한 후의 테이블 상태입니다. |
| previous.table.state | Table State Service가 업데이트되기 전의 테이블 상태입니다. |