PickTablesForReplication 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명¶
Accepts a list of fully qualified table names and determines if a table: - is new (is not replicated, but was added in the source) - is existing (is replicated and exists in the source) - is stale (is replicated but no longer exists in the source) Configuration is passed as a FlowFile attribute. Processor generates a separate FlowFile for each source table.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
Table State Service |
현재 복제된 테이블과 해당 상태를 포함하는 서비스 |
관계¶
이름 |
설명 |
|---|---|
기존 |
이미 복제되고 있는 정규화된 테이블 이름이 포함된 FlowFile |
실패 |
FlowFile 특성을 읽을 수 없거나 올바르지 않은 경우 이 관계로 라우팅됩니다. |
신규 |
복제되지 않은 정규화된 테이블 이름이 포함된 FlowFile |
stale |
소스 데이터베이스에서 제거되었거나 매개 변수에 의해 제외되어 더 이상 복제되지 않는, 이전에 복제되었던 정규화된 테이블 이름이 포함된 FlowFile |
Writes 특성¶
이름 |
설명 |
|---|---|
source.schema.name |
이벤트가 발생한 테이블의 스키마 이름 |
source.table.name |
이벤트가 발생한 테이블의 이름 |