UpdateSnowflakeDatabase 2025.10.2.19¶

번들¶

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

설명¶

Updates the definition of a Snowflake table based on the schema provided in the incoming FlowFile. The schema is expected to be in JSON with the following format, regardless of whether it is provided via FlowFile content or specified as a property: { “columns”: [ { “name”: “<column name>”, “type”: “<column type>”, “nullable”: <true/false>, “precision”: <precision, only for numeric type>, “scale”: <scale, only for numeric type> }, … ], “primaryKeys”: [“<name of first primary key column>”, “<name of second primary key column>”, …] }

태그¶

입력 요구 사항¶

REQUIRED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
Add Column Strategy	수신 스키마에 기존 테이블에 없는 열이 있는 경우 사용할 전략
Add Not Null Strategy	수신 스키마에 기존 테이블에 없는 null이 아닌 제약 조건이 있을 때 사용하는 전략입니다
Alter Column Type Strategy	The strategy to use when the existing table has a column with a different type than the incoming schema.
열 이름 변환	스키마에 정의된 열의 이름에 적용할 수 있는 선택적 변환입니다. 이 변환은 테이블의 기존 열과 비교하기 전에 열 이름에 적용됩니다. 이 속성은 특성 외에도 식 언어를 통해 `column.name`, `column.type`, `column.nullable`, `column.precision`, `column.scale`, `column.primaryKey` 변수를 참조할 수 있습니다.
Column Removal Strategy	기존 테이블에 수신 스키마에 없는 열이 있는 경우 사용할 전략
Connection Pool	Snowflake에 연결하는 데 사용할 연결 풀입니다
스트림 생성하기	테이블에 대한 Snowflake 스트림을 생성할지 여부
생성 매개 변수	CREATE TABLE 문에 포함할 추가 매개 변수. 예: ‘CLUSTER BY (column_name)’
필요한 스키마	필요한 스키마/테이블 정의
Drop Column Strategy	기존 테이블에 수신 스키마에 없는 열이 있는 경우 사용할 전략
Drop Not Null Strategy	기존 테이블에 수신 스키마에 없는 null이 아닌 제약 조건이 있을 때 사용하는 전략
기본값 포함	Whether or not to include DEFAULT values in CREATE TABLE or ALTER TABLE ADD COLUMN statements
Include not null 제약 조건	CREATE TABLE 또는 ALTER TABLE ADD COLUMN 문에 NOT NULL 제약 조건을 포함할지 여부
기본 키 제약 조건 포함하기	생성 문에 기본 키 제약 조건을 포함할지 여부
Max Batch Size	지정된 테이블에 대해 한 번의 실행으로 처리할 수 있는 최대 FlowFiles 개수입니다.
Modify Primary Key Strategy	수신 스키마에 기존 기본 키와 다른 기본 키가 있을 때 사용하는 전략입니다. 기본 키를 수정하려면 기존 키가 있는 경우 삭제하고 새 키를 추가해야 합니다.
Record Reader	원하는 스키마를 얻기 위해 사용할 Record Reader
열 이름 접미사 제거	The suffix to append to a column that was removed. For example, to rename column ‘foo’ to ‘foo__deleted’, the property can be set to `__deleted`
Schema Name	업데이트할 스키마의 이름입니다
스트림 생성 매개 변수	CREATE STREAM 문에 포함할 추가 매개 변수. 예: ‘APPEND_ONLY=TRUE’
스트림 이름	스트림의 이름
테이블 메타데이터 캐시 만료 시간	캐시 항목이 제거될 시간(초)입니다
테이블 이름	스트림을 업데이트하거나 생성할 테이블의 이름입니다
Table Schema Strategy	원하는 스키마/테이블 정의를 얻는 방법을 지정합니다
테이블 스트림 생성 매개 변수	CREATE STREAM 문에 포함할 매개 변수입니다. 예: ‘APPEND_ONLY=TRUE’. 스트림은 소스인 테이블과 함께 생성됩니다.
테이블 스트림 이름	테이블과 함께 생성된 스트림의 이름입니다. 스트림 소스는 생성된 테이블이 됩니다.
업데이트 유형	수행할 업데이트 유형
테이블 메타데이터 캐시 사용	테이블 메타데이터를 Snowflake에서 직접 읽는 대신 캐시할지 여부입니다. [Create Table If Not Exists, Alter Table]에 적용됩니다

관계¶

이름	설명
실패	테이블을 업데이트할 수 없는 경우 수신 FlowFile 은 이 관계로 라우팅됩니다
성공	수신 FlowFile 은 테이블이 성공적으로 업데이트된 후 이 관계로 라우팅됩니다

Writes 특성¶

이름	설명
schema.hash	모든 업데이트가 완료된 후 최종 테이블 스키마의 SHA-256 해시입니다. 변경 감지 및 캐싱 목적으로 사용할 수 있습니다.