UpdateSnowflakeIcebergDatabase 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
설명¶
Snowflake Iceberg 테이블의 정의를 업데이트합니다. 대상 스키마는 RecordReader에서 추론하거나 { “columns”: [ { “name”: “<column name>”, “type”: “<iceberg data type>” }, … ] } 형식을 사용하여 명시적으로 정의할 수 있습니다. 여기서 다음이 적용됩니다. <iceberg data type>은 기본 iceberg 유형(“string”, “int”, “boolean”,…) - 지정된 전체 자릿수와 소수점 이하 자릿수의 십진수(“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>] }
입력 요구 사항¶
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 은 이 관계로 라우팅됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
schema.hash |
모든 업데이트가 완료된 후 최종 테이블 스키마의 16진수로 인코딩된 SHA-256 해시입니다. |