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 입니다.