UpdateSnowflakeView 2025.10.2.19¶

Pacote¶

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

Descrição¶

Cria ou substitui exibições do Snowflake com base nos mapeamentos de colunas fornecidos no FlowFile de entrada. O processador verifica se a exibição existe e só a recria se a definição tiver mudado. O conteúdo do FlowFile deve ter JSON com mapeamentos de colunas, configuração opcional de junção e configuração opcional de nivelamento: { «columns»: [ { «source_field»: «customer_data:id», «destination_column»: «customer_id», «type»: «VARCHAR» }, { «source_field»: «f.value:order_amount», «destination_column»: «order_amount», «type»: «NUMBER» }, { «expression»: «SUM(f.value:order_amount::NUMBER)», «destination_column»: «total_amount» }, { «expression»: «COUNT(*)», «destination_column»: «order_count» } ], «from»: { «table»: «raw_data», «alias»: «rd», «joins»: [ { «type»: «INNER», «table»: «customers», «alias»: «c», «on»: «customer_data:id::VARCHAR = c.customer_id» } ] }, «flatten»: [ { «input»: «rd.orders», «alias»: «f», «path»: null } ], «where»: «active = true AND status =”VALID”», «group_by»: [«customer_id», «region»], «order_by»: [«order_amount DESC», «customer_id ASC»] } A configuração da coluna aceita: - source_field: Referência simples de campo/coluna (suporte para notação JSON como “data:field” ou aliases de tabela como “t.column”) – expression: expressão SQL complexa (por exemplo, “SUM(quantidade)», «COUNT(*)”) – destination_column: o nome da coluna de saída na exibição (opcional - gerado automaticamente se não for fornecido) - type: tipo de dados do Snowflake para conversão automática de tipo (VARCHAR, NUMBER, BOOLEAN, DATE, TIMESTAMP, etc.) Use source_field OR expression, não ambos. Quando type é especificado, a conversão automática de tipo é aplicada. Quando type é omitido, a expressão é usada no estado em que se encontra, sem conversão. A configuração de nivelamento oferece suporte a: – input: o campo/coluna aninhado a ser nivelado (obrigatório) – alias: alias para os dados nivelados (obrigatório) - path: caminho opcional dentro da estrutura aninhada A seção “from” é obrigatória e especifica a tabela de origem e as junções opcionais. Cláusulas SQL opcionais podem ser incluídas: - where: condição da cláusula WHERE (por exemplo, «active = true AND status =”VALID”») - group_by: cláusula GROUP BY como uma matriz de nomes de colunas (por exemplo, [«customer_id», «region»]) - order_by: cláusula ORDER BY como uma matriz de coluna/expressão com direção (por exemplo, [«order_amount DESC», «customer_id ASC»])

Tags¶

nivelamento, exibição

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Relações¶