PickTablesForReplication 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명¶
정규화된 테이블 이름 목록을 허용하고 테이블이 다음 중 어떤 경우인지 확인합니다. - 새 테이블(복제되지 않았지만 소스에 추가됨) - 기존 테이블(복제되고 소스에 존재함) - 부실 테이블(복제되었지만 더 이상 존재하지 않음). 구성은 FlowFile 특성으로 전달됩니다. 프로세서는 각 소스 테이블에 대해 별도의 FlowFile을 생성합니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
Table State Service |
현재 복제된 테이블과 해당 상태를 포함하는 서비스 |
관계¶
이름 |
설명 |
|---|---|
기존 |
이미 복제되고 있는 정규화된 테이블 이름이 포함된 FlowFile |
실패 |
FlowFile 특성을 읽을 수 없거나 올바르지 않은 경우 이 관계로 라우팅됩니다. |
신규 |
복제되지 않은 정규화된 테이블 이름이 포함된 FlowFile |
stale |
소스 데이터베이스에서 제거되었거나 매개 변수에 의해 제외되어 더 이상 복제되지 않는, 이전에 복제되었던 정규화된 테이블 이름이 포함된 FlowFile |
Writes 특성¶
이름 |
설명 |
|---|---|
source.schema.name |
이벤트가 발생한 테이블의 스키마 이름 |
source.table.name |
이벤트가 발생한 테이블의 이름 |