UpdateSnowflakeIcebergDatabase 2025.5.31.15

번들

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

설명

Snowflake Iceberg 테이블의 정의를 업데이트합니다. 대상 스키마는 RecordReader 에서 추론하거나 { “columns”: [ { “name”: “<column name>”, “type”: “<iceberg data type>” }, … ]} 형식을 사용하여 명시적으로 정의할 수 있습니다. 여기서 <Iceberg 데이터 타입>은 원시 Iceberg 타입(“문자열”, “int”, “부울”,…)- 주어진 전체 자릿수와 스케일을 가진 소수점 (“decimal(P,S)”)- {“type”: “list”, “element”: <iceberg data type>}- {“type”: “map”, “key”: <iceberg data type>, “value”: <iceberg data type>}- {“type”: “struct”, “fields”:[<list of struct fields>] } 중 하나 일 수 있습니다.

태그

Iceberg

입력 요구 사항

REQUIRED

민감한 동적 속성 지원

false

속성

속성

설명

Add Column Strategy

수신 스키마에 기존 테이블에 없는 열이 있는 경우 사용할 전략

Alter Column Strategy

수신 스키마에서 열의 데이터 타입이 기존 테이블과 다른 경우 사용할 전략

Connection Pool

Snowflake에 연결하는 데 사용할 연결 풀입니다

필요한 스키마

필요한 스키마/테이블 정의

Drop Column Strategy

기존 테이블에 수신 스키마에 없는 열이 있는 경우 사용할 전략

Max Batch Size

지정된 테이블에 대해 한 번의 실행으로 처리할 수 있는 최대 FlowFiles 개수입니다.

Record Reader

원하는 스키마를 얻기 위해 사용할 Record Reader

Schema Name

업데이트할 스키마의 이름입니다

테이블 메타데이터 캐시 만료 시간

캐시 항목이 제거될 시간(초)입니다

테이블 이름

업데이트할 테이블의 이름입니다

Table Schema Strategy

원하는 스키마/테이블 정의를 얻는 방법을 지정합니다

테이블 메타데이터 캐시 사용

테이블 메타데이터를 Snowflake에서 직접 읽는 대신 캐시할지 여부

관계

이름

설명

실패

테이블을 업데이트할 수 없는 경우 수신 FlowFile 은 이 관계로 라우팅됩니다

불법 변경

업데이트에 실패하도록 구성된 변경이 필요한 경우 수신 FlowFile 은 이 관계로 라우팅됩니다

성공

수신 FlowFile 은 테이블이 성공적으로 업데이트된 후 이 관계로 라우팅됩니다

table not found

지정된 테이블이 존재하지 않으면 수신 FlowFile 은 이 관계로 라우팅됩니다.