MergeSnowflakeJournalTable 2025.5.31.15¶
번들¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
설명¶
저널 테이블에서 대상 테이블로의 변경 사항에 대해 Snowflake에서 병합 작업을 트리거합니다. 병합 작업은 비동기적으로 수행되며 프로세서는 작업 결과를 폴링합니다. 쿼리가 여전히 진행 중이면 플로우 파일에 불이익이 적용됩니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
---|---|
대상 데이터베이스 이름 |
데이터가 수집되고 있는 Snowflake 데이터베이스의 이름입니다. |
쿼리 재시도 횟수 병합 |
병합 쿼리가 실패할 경우 다시 시도할 횟수를 나타냅니다. |
Record Reader |
입력을 읽는 데 사용할 Record Reader |
Snowflake 연결 풀 |
병합 작업을 수행하기 위해 Snowflake 데이터베이스에 대한 연결을 얻는 데 사용되는 컨트롤러 서비스입니다. |
관계¶
이름 |
설명 |
---|---|
ddl |
실행할 DDL 입니다. |
압축 중 삭제됨 |
테이블 이름 및 생성에 따라 압축 중에 삭제된 FlowFile 입니다. |
실패 |
실패 쿼리 실행. |
실패 재시도 |
실패한 쿼리 실행을 다시 시도합니다. |
투표 쿼리 결과 |
예약된 비동기 쿼리 실행. |
성공 |
쿼리 실행 성공. |
알 수 없는 파일 형식 |
알 수 없는 파일 형식입니다. |
Writes 특성¶
이름 |
설명 |
---|---|
merge.query.id |
저널 테이블을 대상 테이블에 병합하는 데 사용되는 쿼리의 ID 입니다. |