EnrichCdcStream 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명¶
Enriches incoming FlowFiles that come from CaptureChangePostgreSQL, etc. with information pertaining to which Journal Table to write to and relevant schema information. This Processor manages the schema versions for each table being processed in order to ensure that the correct Journal Table is used for each FlowFile.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
CDC Schema Registry |
CDC 데이터의 스키마를 관리하는 데 사용할 CDC Schema Registry를 지정합니다 |
Record Reader |
수신 데이터를 읽는 데 사용할 Record Reader를 지정합니다 |
Record Writer |
발신 데이터 쓰기에 사용할 Record Writer를 지정합니다 |
Table State Service |
복제된 테이블의 상태를 보유합니다 |
상태 관리¶
범위 |
설명 |
|---|---|
CLUSTER |
처리 중인 각 테이블의 현재 저널 테이블 버전을 추적합니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFile 을 읽을 수 없는 경우 이 관계로 라우팅됩니다. |
schema update |
수신 레코드를 처리하기 위해 스키마 업데이트가 필요한 경우 FlowFile 은 이 관계로 라우팅됩니다. FlowFile 에는 변경이 필수임을 나타내는 스키마 정보가 포함됩니다. |
skipped ddl event |
이 관계는 대상 테이블의 스키마 변경을 초래하지 않는 DDL / 스키마 변경 이벤트에 사용됩니다. |
성공 |
Snowflake 테이블에 삽입할 행은 이 관계로 라우팅됩니다. |
table not in state |
FlowFile 이 복제된 테이블의 상태에 존재하지 않는 테이블을 참조할 때(아마도 복제에서 제거된 후) 사용됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
table.schema.generation |
증분 처리를 위한 저널 테이블의 인덱스입니다. |
table.schema.initial |
저널 테이블의 초기 생성을 표시합니다. |
destination.table.schema |
대상 테이블에 대한 업데이트된 스키마입니다. 이 특성은 DDL 이벤트에만 작성됩니다. |