UpdateSnowflakeIcebergDatabase 프로세서

Openflow의 UpdateSnowflakeIcebergDatabase 프로세서는 Snowflake Iceberg 테이블 정의를 업데이트하는 데 사용합니다. 이 문서에서 프로세서의 번들, 설명, 속성, 관계 등을 확인할 수 있습니다.

출처: Snowflake 문서

본문

번들 (Bundle)

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

설명 (Description)

Snowflake Iceberg 테이블의 정의를 업데이트합니다. 대상 스키마는 RecordReader에서 추론하거나 아래 형식으로 명시적으로 정의할 수 있습니다: { "columns": [ { "name": "<column name>", "type": "<iceberg data type>" }, … ] } 여기서 은 다음 중 하나입니다: - 기본 iceberg 유형("string", "int", "boolean", ...) - 주어진 precision과 scale을 가진 decimal("decimal(P,S)") - {"type": "list", "element": } - {"type": "map", "key": , "value": } - {"type": "struct", "fields":[] }

태그 (Tags)

iceberg

입력 요구사항 (Input Requirement)

REQUIRED

민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)

false

속성 (Properties)

속성 (Property)	설명 (Description)
Add Column Strategy	들어오는 스키마에 기존 테이블에는 없는 열이 있을 때 사용할 전략입니다.
Alter Column Strategy	들어오는 스키마의 열 데이터 유형이 기존 테이블과 다를 때 사용할 전략입니다.
Alter Column Type Strategy	기존 테이블의 열 유형이 들어오는 스키마와 다를 때 사용할 전략입니다.
Connection Pool	Snowflake에 연결하는 데 사용할 연결 풀입니다.
Desired Schema	원하는 스키마/테이블 정의입니다.
Drop Column Strategy	기존 테이블에 들어오는 스키마에는 없는 열이 있을 때 사용할 전략입니다.
Max Batch Size	주어진 테이블에 대해 단일 실행에서 처리할 수 있는 최대 FlowFile 수입니다.
Record Reader	원하는 스키마를 얻는 데 사용할 Record Reader입니다.
Schema Name	업데이트할 스키마의 이름입니다.
Table Metadata Cache Expiration Time	캐시 항목이 제거된 후의 시간(초)입니다.
Table Name	업데이트할 테이블의 이름입니다.
Table Schema Strategy	원하는 스키마/테이블 정의를 얻는 방법을 지정합니다.
Use Table Metadata Cache	Snowflake에서 직접 읽는 대신 테이블의 메타데이터를 캐시할지 여부입니다.

관계 (Relationships)

이름 (Name)	설명 (Description)
failure	테이블을 업데이트할 수 없으면 들어오는 FlowFile이 이 관계로 라우팅됩니다.
illegal alteration	업데이트가 실패하도록 구성된 변경(alteration)을 요구하면 들어오는 FlowFile이 이 관계로 라우팅됩니다.
success	테이블이 성공적으로 업데이트된 후 들어오는 FlowFile이 이 관계로 라우팅됩니다.
table not found	지정된 테이블이 존재하지 않으면 들어오는 FlowFile이 이 관계로 라우팅됩니다.

기록하는 속성 (Writes attributes)

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

더 알아보기 (Learn more)

UpdateSnowflakeIcebergDatabase 프로세서 - Snowflake 문서