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>] } 중 하나 일 수 있습니다.
입력 요구 사항¶
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 은 이 관계로 라우팅됩니다. |