PickTablesForReplication 2025.5.31.15¶

번들¶

com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar

설명¶

정규화된 테이블 이름 목록을 받아 테이블이 - 신규(복제되지 않았지만 소스에 추가됨) - 기존(복제되었고 소스에 존재함) - 부실(복제되었지만 소스에 더 이상 존재하지 않음)인지를 결정합니다. 구성은 FlowFile 특성으로 전달됩니다. 프로세서는 각 소스 테이블에 대해 별도의 FlowFile 을 생성합니다.

태그¶

snowflake, state, table

입력 요구 사항¶

REQUIRED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
Table State Service	현재 복제된 테이블과 해당 상태를 포함하는 서비스

관계¶

이름	설명
기존	이미 복제되고 있는 정규화된 테이블 이름이 포함된 FlowFile
실패	FlowFile 특성을 읽을 수 없거나 올바르지 않은 경우 이 관계로 라우팅됩니다.
신규	복제되지 않은 정규화된 테이블 이름이 포함된 FlowFile
stale	소스 데이터베이스에서 제거되었거나 매개 변수에 의해 제외되어 더 이상 복제되지 않는, 이전에 복제되었던 정규화된 테이블 이름이 포함된 FlowFile

Writes 특성¶

이름	설명
source.schema.name	이벤트가 발생한 테이블의 스키마 이름
source.table.name	이벤트가 발생한 테이블의 이름