FetchTableSnapshot 2025.10.2.19¶
Pacote¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Descrição¶
Fetches a snapshot of a table from a database. The snapshot is fetched incrementally, using the primary key columns of the table to fetch rows in batches. Replicating a table without primary key is not supported. The snapshot is written to a FlowFile in the specified Record Writer format. The input FlowFile is expected to consist of a JSON representation of the table schema in the following format: { «columns»: [{ «name»: «<column name>», «type»: «<column type>» }, { «name»: «<column name>», «type»: «<column type>» }, … ], «primaryKeys»: [«<name of first primary key column>», «<name of second primary key column>», …] } Only those columns that are specified in the schema will be fetched from the table.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Pool de conexões |
O pool de conexões a ser usado para buscar o instantâneo do banco de dados |
Tamanho da busca |
O número máximo de linhas carregadas na memória de uma só vez |
Local do driver JDBC |
Lista separada por vírgulas de arquivos/pastas e/ou URLs contendo o driver JAR e suas dependências (se houver). Por exemplo, “/var/tmp/postgresql-java-client-42.7.5.jar” |
Tamanho máximo do lote |
O número máximo de linhas a serem buscadas em um único lote |
Record Writer |
O Record Writer a ser usado para gravar o instantâneo obtido |
Nome do esquema |
O nome do esquema no qual o instantâneo deve ser obtido |
Nome da tabela |
O nome da tabela na qual o instantâneo será obtido |
Relações¶
Nome |
Descrição |
|---|---|
complete |
Quando o instantâneo for concluído, o FlowFile original será encaminhado para essa relação |
failure |
Se os dados não puderem ser recuperados da tabela representada pelo FlowFile, o FlowFile será encaminhado para essa relação. |
retryable failure |
Se os dados não puderem ser recuperados da tabela representada pelo FlowFile, mas esperamos que isso seja possível no futuro, o FlowFile será encaminhado para essa relação. |
rows |
Quando o instantâneo for recuperado com sucesso da tabela representada pelo FlowFile, as linhas serão encaminhadas para essa relação. |
Grava atributos¶
Nome |
Descrição |
|---|---|
snapshot.complete |
Indica se o instantâneo está completo |
rows.total.fetched |
O número total de linhas obtidas para a tabela |
rows.delta.fetched |
O número de linhas obtidas para a tabela na última iteração |
start.row.index |
O índice da primeira linha no instantâneo para uma determinada iteração, começando em 0 |
last.row.index |
O índice da última linha no instantâneo para uma determinada iteração, começando em 0 |
fetch.delta.time.in.millis |
O tempo, em milissegundos, necessário para buscar as linhas na última iteração |
fetch.total.time.in.millis |
O tempo em milissegundos gasto até o momento para buscar as linhas |