PickTablesForReplication
PickTablesForReplication
정규화된(fully qualified) 테이블 이름 목록을 받아 각 테이블이 신규(new), 기존(existing), 또는 오래된(stale) 상태인지 판별하는 프로세서예요.
본문
번들 (Bundle)
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명
정규화된 테이블 이름 목록을 받아 각 테이블이 다음 중 어느 것인지 판별해요.
- 신규(new): 복제되고 있지 않지만 소스에 추가된 테이블
- 기존(existing): 복제되고 있으며 소스에 존재하는 테이블
- 오래됨(stale): 복제되고 있지만 더 이상 소스에 존재하지 않는 테이블
구성은 FlowFile 속성으로 전달돼요. 이 프로세서는 각 소스 테이블에 대해 별도의 FlowFile을 생성해요.
태그
snowflake, state, table
입력 요구 사항 (Input Requirement)
REQUIRED — 입력 FlowFile이 필요해요.
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false — 지원하지 않아요.
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Table State Service | 현재 복제 중인 테이블과 그 상태를 담고 있는 서비스예요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
existing |
이미 복제되고 있는 정규화된 테이블 이름이 담긴 FlowFile이 이 관계로 이동해요. |
failure |
FlowFile 속성을 읽을 수 없거나 올바르지 않으면 이 관계로 라우팅돼요. |
new |
복제되고 있지 않은 정규화된 테이블 이름이 담긴 FlowFile이 이 관계로 이동해요. |
stale |
이전에는 복제됐지만 더 이상 복제되지 않는(소스 데이터베이스에서 제거되었거나 매개변수로 제외된) 정규화된 테이블 이름이 담긴 FlowFile이 이 관계로 이동해요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
source.schema.name |
이벤트가 발생한 테이블의 스키마 이름이에요. |
source.table.name |
이벤트가 발생한 테이블의 이름이에요. |