CREATE FLOW (pipeline declarativo LakeFlow )
Use a instrução CREATE FLOW para criar fluxos ou preenchimentos para suas tabelas de pipeline declarativas LakeFlow .
Sintaxe
CREATE FLOW flow_name [COMMENT comment] AS
{
  AUTO CDC INTO target_table create_auto_cdc_flow_spec |
  INSERT INTO [ONCE] target_table BY NAME query
}
Parâmetros
- 
nome_do_fluxo O nome do fluxo a ser criado. 
- 
comentário Uma descrição opcional para o fluxo. 
- 
Uma instrução AUTO CDC ... INTOque define o fluxo, com umcreate_auto_cdc_flow_spec. Você deve incluir uma declaraçãoAUTO CDC ... INTOou uma declaraçãoINSERT INTO. UseAUTO CDC ... INTOquando a consulta de origem usar semântica de dados alterados.Para obter mais informações, consulte AUTO CDC INTO (pipeline declarativo LakeFlow ). 
- 
tabela_alvo A tabela a ser atualizada. Esta deve ser uma tabela de transmissão. 
- 
INSERT INTO Define uma consulta de tabela que é inserida na tabela de destino. Se a opção ONCEnão for fornecida, a consulta deverá ser uma consulta de transmissão . Use a palavra-chave transmissão para usar a semântica de transmissão para ler a fonte. Se a leitura encontrar uma alteração ou exclusão em um registro existente, um erro será gerado. É mais seguro ler de fontes estáticas ou somente de acréscimos. Para ingerir dados que tenham confirmação de alteração, você pode usar Python e a opçãoSkipChangeCommitspara lidar com erros.INSERT INTOé mutuamente exclusivo comAUTO CDC ... INTO. UseAUTO CDC ... INTOquando os dados de origem incluem a funcionalidade de captura de dados de alterações (CDC) (CDC). UseINSERT INTOquando a fonte não o fizer.Para mais informações sobre transmissão de dados, veja transformação de dados com pipeline. 
- 
UMA VEZ Opcionalmente, defina o fluxo como um fluxo único, como um aterro. Usar ONCEaltera o fluxo de duas maneiras:- A fonte queryoucreate_auto_cdc_flow_specnão é uma tabela de transmissão.
- O fluxo é executado uma vez por default. Se o pipeline for atualizado com uma refresh completa, o fluxo ONCEserá executado novamente para recriar os dados.
 
- A fonte 
Exemplos
-- EXAMPLE 1:
-- Create a streaming table, and add two flows that append data to it:
CREATE OR REFRESH STREAMING TABLE users;
-- first flow into target_table:
CREATE FLOW users_flow AS
INSERT INTO users
SELECT * FROM stream(raw_data.users);
-- second flow into target_table:
CREATE FLOW backfill_users AS
INSERT INTO ONCE users
SELECT * FROM user_backfill_table;
-- EXAMPLE 2:
-- Create a streaming table, and add a flow that applies CDC changes to it:
CREATE OR REFRESH STREAMING TABLE admins_cdc_target_table;
-- first flow into target_table:
CREATE FLOW admin_cdc_flow AS
AUTO CDC INTO admins_cdc_target_table
FROM stream(cdc_data.admins)
KEYS (userId)
APPLY AS DELETE WHEN
  operation = "DELETE"
SEQUENCE BY sequenceNum
COLUMNS * EXCEPT (operation, sequenceNum)
STORED AS SCD TYPE 2;