UpdateSnowflakeIcebergDatabase 2025.10.2.19¶

번들¶

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

설명¶

Updates the definition of a Snowflake Iceberg table. A target schema can be inferred from a RecordReader or defined explicitly using the format below: { “columns”: [ { “name”: “<column name>”, “type”: “<iceberg data type>” }, … ] } where <iceberg data type> can be one of: - primitive iceberg type (“string”, “int”, “boolean”,…) - decimal with given precision and scale (“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	수신 스키마에서 열의 데이터 타입이 기존 테이블과 다른 경우 사용할 전략
Alter Column Type Strategy	The strategy to use when the existing table has a column with a different type than the incoming schema.
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 은 이 관계로 라우팅됩니다.

Writes 특성¶

이름	설명
schema.hash	모든 업데이트가 완료된 후 최종 테이블 스키마의 16진수로 인코딩된 SHA-256 해시입니다.