ExtractSchemaColumns 2025.5.31.15¶
Pacote¶
com.snowflake.openflow.runtime | runtime-record-schema-nar
Descrição¶
Extrai as colunas do esquema de registro do FlowFile usando o Record Reader fornecido e as grava no atributo schema.columns.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Índice da coluna final |
Especifica o índice da coluna no esquema para o qual as colunas devem ser levadas. |
Record Reader |
Especifica o Controller Service a ser usado para ler os dados recebidos |
Índice da coluna inicial |
Especifica o índice da coluna (numerada a partir de 1) no esquema do qual as colunas devem ser extraídas. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Se o esquema de registro do FlowFile não puder ser extraído do formato de entrada configurado, o FlowFile será encaminhado para essa relação |
success |
FlowFiles cujos esquemas de registros forem extraídos com sucesso serão encaminhados para essa relação |
Grava atributos¶
Nome |
Descrição |
|---|---|
record.error.message |
Esse atributo fornece, em caso de falha, a mensagem de erro encontrada pelo leitor. |
schema.columns |
Esse atributo fornece colunas extraídas do FlowFile de entrada usando o RecordReader fornecido. |