PutIcebergTable 프로세서
PutIcebergTable 프로세서
PutIcebergTable은 설정 가능한 Catalog를 사용해 Iceberg에 레코드를 저장하고 네임스페이스와 테이블을 관리하는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle com.snowflake.openflow.runtime | runtime-iceberg-processors-nar
설명
설정 가능한 Catalog를 사용해 네임스페이스와 테이블을 관리하면서 Iceberg에 레코드를 저장해요.
Tags analytics, iceberg, openflow, parquet, polaris, s3
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Iceberg Catalog | Iceberg Catalog용 Provider Service예요. |
| Iceberg Writer | 포맷된 Iceberg 데이터 파일을 생성하는 Iceberg Row Writer용 Provider Service예요. |
| Namespace | 테이블을 포함하는 Iceberg 네임스페이스예요. |
| Record Reader | 들어오는 FlowFile용 Record Reader예요. |
| Table Name | Iceberg 테이블 이름이에요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | Iceberg로 전송되지 않은 FlowFile이에요. |
| success | Iceberg로 전송된 FlowFile이에요. |