MergeSnowflakeJournalTable 2025.10.2.19¶

번들¶

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

설명¶

Triggers a merge operation on changes from journal table to a destination table in Snowflake. The merge operation is performed asynchronously and the processor polls the result of the operation. If the query is still in progress the FlowFile will be penalized.

태그¶

입력 요구 사항¶

REQUIRED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
대상 데이터베이스 이름	데이터가 수집되고 있는 Snowflake 데이터베이스의 이름입니다.
쿼리 재시도 횟수 병합	병합 쿼리가 실패할 경우 다시 시도할 횟수를 나타냅니다.
오브젝트 식별자 확인	Snowflake에서 소스 오브젝트 식별자(스키마, 테이블, 열)를 저장하고 쿼리하는 방법을 제어합니다. 이 설정은 SQL 쿼리에서 큰따옴표를 사용해야 하는지 여부를 결정합니다. ‘대소문자 구분’ 옵션은 기본 프로덕션 동작입니다. ‘대소문자 구분 안 함’은 당분간 미리 보기로 간주됩니다.
자리 표시자 값	MERGE에서 찾을 페이로드 자리 표시자의 값입니다. 이는 대상 열의 데이터 타입으로 변환됩니다.
Snowflake 연결 풀	병합 작업을 수행하기 위해 Snowflake 데이터베이스에 대한 연결을 얻는 데 사용되는 컨트롤러 서비스입니다.
변경되지 않은 값 전략	MERGE 쿼리가 저널 열의 변경되지 않은 값을 처리하는 방법을 결정합니다. 기본적으로 전체 값을 예상합니다.

관계¶

이름	설명
ddl	실행할 DDL 입니다.
압축 중 삭제됨	테이블 이름 및 생성에 따라 압축 중에 삭제된 FlowFile 입니다.
실패	실패 쿼리 실행.
실패 재시도	실패한 쿼리 실행을 다시 시도합니다.
투표 쿼리 결과	예약된 비동기 쿼리 실행.
성공	쿼리 실행 성공.
알 수 없는 파일 형식	알 수 없는 파일 형식입니다.

Writes 특성¶

이름	설명
merge.query.id	저널 테이블을 대상 테이블에 병합하는 데 사용되는 쿼리의 ID 입니다.