Pular para o conteúdo

Matriz de conversão do Prophecy

O PlaidCloud converte pipelines Spark e projetos SQL do Prophecy em fluxos de trabalho avançados nativos. O importador mapeia cada gem do Prophecy para um passo de fluxo de trabalho, uma variável de projeto ou um objeto da área de desenho, pelo que um fluxo de trabalho convertido é executado de forma nativa na nuvem e não como uma emulação.

Todas as gems, conectores e estruturas de projeto são convertidos: Completo significa que a gem se torna um passo, uma variável ou um objeto de área de desenho nativo do PlaidCloud que executa o trabalho da gem. Os poucos comportamentos que um fluxo de trabalho convertido não reproduz por si estão listados em Casos limite conhecidos, cada um com o que fazer.

Para executar uma conversão, consulte Migrar projetos do Prophecy.

Gem Estado Equivalente no PlaidCloud Conversão
Lookup Completo Pesquisa Cada chamada de pesquisa torna-se um passo Pesquisa no passo que a utiliza; uma chave sem correspondência devolve NULL e uma chave duplicada devolve uma das suas linhas.
Source Completo Passo de importação escolhido pelo formato do conjunto de dados (consulte Conectores) Cada Source torna-se um passo de importação para uma tabela com o nome do conjunto de dados; um formato que o conversor não reconhece é lido como um ficheiro CSV carregado para a pasta de documentos do fluxo de trabalho, com um aviso.
Streaming Source Completo A mesma importação que um Source em lote Os sources de streaming são convertidos numa importação em lote única, com um aviso.
Streaming Target Completo Carregamento em lote com acréscimo Os targets de streaming são convertidos num acréscimo em lote, com um aviso.
Target Completo Passo de exportação/carregamento de tabela escolhido pelo formato do conjunto de dados e por writeMode Cada Target torna-se um passo de carregamento ou exportação de tabela no modo de escrita da gem: acréscimo, substituição, fusão com as respetivas expressões SET, upsert, SCD2, replaceWhere e insertInto.
Gem Estado Equivalente no PlaidCloud Conversão
Data Cleansing Completo Expressões de coluna num passo Table Extract Converte as opções de preenchimento de nulos, remoção de espaços e capitalização em expressões de coluna; as colunas limpas passam para o fim.
Sequence Completo Table Extract com uma expressão de número de linha Acrescenta uma coluna de sequência a partir do valor inicial e do incremento.
Surrogate Key Generator Completo Table Extract com uma expressão de número de linha Acrescenta uma chave sequencial a partir do valor inicial; as chaves continuam entre execuções a partir de uma tabela que guarda a última chave emitida.
Gem Estado Equivalente no PlaidCloud Conversão
Aggregate Completo Table Extract com agregação; Pivot quando a gem faz pivô Agrupa e agrega, aplica a condição HAVING e faz o pivô para uma coluna por valor de pivô; propagate-all transporta todas as outras colunas de entrada.
Bulk Column Expressions Completo Expande para uma expressão por coluna num passo Table Extract Uma expressão por coluna listada num passo Table Extract; a conversão avisa que se presume o esquema da gem.
Bulk Column Rename Completo Mudança de nome de coluna num passo Table Extract Uma mudança de nome por coluna listada num passo Table Extract; a conversão avisa que se presume o esquema da gem.
Deduplicate Completo Table Extract com distinct ou um filtro de número de linha Mantém uma linha por chave: distinct, a primeira ou a última segundo a sua ordem de ordenação, qualquer uma, ou apenas as chaves que ocorrem uma vez.
Dynamic Replace Completo Transformação de substituição dinâmica, configurada manualmente Converte-se em regras de substituição na transformação de substituição dinâmica; a conversão avisa que se presume o esquema da gem.
Dynamic Select Completo Seleção de colunas num passo Table Extract resolvida por tipo Resolve as colunas por tipo no momento da conversão numa seleção explícita.
Filter Completo Table Extract com uma expressão de filtro Converte-se num passo Table Extract com uma expressão de filtro; as condições NULL eliminam a linha.
Flatten Schema Completo Analisar JSON e Table Extract Aplana os campos aninhados em colunas com o nome formado pelo delimitador da gem e expande as matrizes numa linha por elemento.
Fuzzy Match Completo Table Extract e User Defined Transform Emparelha os registos, pontua cada campo de correspondência pelo método da gem, calcula a média das pontuações e mantém os pares iguais ou superiores ao seu limiar.
Group By Rollup Completo União de passos de agregação Table Extract por nível de rollup Expande o rollup numa agregação por nível de agrupamento, unidas com subtotais NULL.
Limit Completo Table Extract com um limite de linhas Converte-se num limite de linhas; as referências de configuração tornam-se variáveis de projeto.
Normalize Completo Table Extract com uma expressão de expansão Repete cada registo segundo a expressão de comprimento, calcula as colunas de saída por índice e para no primeiro índice em que a condição de conclusão se verifica.
Order By Completo Ordenação num passo Table Extract Converte-se numa ordenação com as mesmas chaves, direção e posição dos nulos.
Reformat Completo Table Extract com expressões de coluna Converte-se num passo Table Extract com uma expressão por coluna de saída; as colunas não listadas são eliminadas.
Sample Rows Completo Table Extract com um limite de linhas ou amostra aleatória Mantém uma fração ou um número aleatório de linhas; as linhas escolhidas diferem da execução em Spark porque a amostragem é aleatória.
Schema Transform Completo Cadeia de passos Table Extract aplicados por ordem Aplica cada operação por ordem: acrescentar ou substituir uma coluna, eliminar, mudar o nome, acrescentar se estiver em falta com o seu valor predefinido e acrescentar uma regra de negócio do projeto.
Set Operation Completo União total; Anti-junção para except; Junção interna para intersect Union all empilha as entradas; except all e intersect all mantêm o número correto de linhas duplicadas.
TransposeAgg Completo Table Extract com agregação Converte o agrupamento, as agregações e o pivô da gem como um Aggregate, com um aviso para o rever.
Unpivot Completo Melt Empilha as colunas selecionadas em colunas de nome e de valor.
Watermark Completo Não é necessário nenhum passo Descartado: uma execução em lote lê todos os dados presentes, pelo que não há limite de dados tardios a aplicar.
Window Function Completo Expressões de janela num passo Table Extract Acrescenta colunas de janela com a partição, a ordem e o quadro da gem, em linhas ou intervalo, com limites ilimitados, na linha atual ou com deslocamento.
Gem Estado Equivalente no PlaidCloud Conversão
Compare Columns Completo Junção externa completa mais agregações por coluna Compara as colunas através de uma junção externa completa dos dados desagregados, com contagens de correspondências e de divergências.
Join Completo Junção interna, Junção de várias tabelas, Anti-junção ou Junção cruzada Constrói a junção de cada tipo, interna, à esquerda, à direita, completa, semi, anti, cruzada e natural, com qualquer condição de junção, aplica a cláusula where e escreve a lista de seleção.
Repartition Completo Não é necessário nenhum passo Descartado: o PlaidCloud gere a partição, pelo que o passo seguinte lê diretamente a tabela a montante.
Row Distributor Completo Um filtro Table Extract por saída Converte-se num filtro por saída; as linhas podem terminar em várias saídas.
Gem Estado Equivalente no PlaidCloud Conversão
Column Parser Completo Analisar JSON / Análise de XML Converte-se numa análise de JSON ou XML da coluna indicada; a conversão avisa que se presume o esquema da gem.
Gem Estado Equivalente no PlaidCloud Conversão
Custom Gem (Gem Builder) Completo User Defined Transform que executa o código gerado da gem O código PySpark gerado da gem, a partir da exportação do pipeline, é executado num passo Python, com um aviso para o rever.
CustomReformatBitbucket Completo Table Extract Converte-se como o Reformat cujas expressões a gem contém, com um aviso para o rever.
Data Quality Check Completo União total de uma linha de resultado por verificação; Gerar erro de fluxo de trabalho para parar em caso de falhas Avalia cada verificação sobre a entrada e escreve uma linha de resultado por verificação, com o respetivo estado e mensagem. Os dados passam sem alterações e a execução pára quando o limiar de falhas da gem é atingido.
Deequ Completo Verificações Table Extract Transmite os dados e constrói a tabela de resultados das restrições para as regras isComplete, isUnique, isNonNegative e isContainedIn.
Delta Table Operations Completo Table In-Place Delete, Table Update, Table Drop, Table Restore to Timestamp Eliminar, atualizar, remover e restaurar para uma marca temporal correspondem a passos de tabela; otimizar, vacuum e restaurar por versão transmitem os dados com um aviso.
Directory Completo Listagem de diretório Lista os ficheiros da pasta de documentos associada nas colunas da gem; com a opção de nome da folha, cada livro produz uma linha por folha. Uma pasta em falta produz zero linhas.
Email Completo Notify Via Email Envia a mensagem de correio eletrónico, com um anexo de dados opcional, através de uma ligação de correio eletrónico associada.
Email Data Completo Notify Via Email Envia por correio eletrónico as linhas de entrada como tabela e transmite a entrada sem alterações.
File Operation Completo Copy Document File ou Copy Document Directory Copia, move ou sincroniza ficheiros da pasta de documentos associada para a pasta de documentos do fluxo de trabalho convertido; uma movimentação remove os ficheiros de origem.
Log Completo Table Extract Escreve a linha de evento da gem (hora, nome da gem, tipo de evento e texto) na sua tabela de saída.
REST API Enrich Completo Pedido REST Chama a API uma vez por linha e acrescenta as colunas da resposta.
Script Completo Passo Python com reescrita do acesso a frames Incorpora o corpo do script num passo Python, com o acesso a data frames reescrito; os corpos em Scala são mantidos com uma nota.
Soda Data Quality Check Completo Verificações Table Extract Constrói a tabela de resultados das verificações a partir das verificações Soda.
SQL Statement Completo Passo SQL por separador de saída, com o texto traduzido para o dialeto do inquilino Incorpora cada separador como um passo SQL com as entradas associadas como tabelas temporárias; traduzido para o dialeto do inquilino.
Todo Completo Gerar erro de fluxo de trabalho ou Notify via Log Assinala lógica ainda por escrever: uma mensagem de registo quando nada a lê, ou um passo que pára a execução com a mensagem da gem quando um passo posterior depende dela.
Gem Estado Equivalente no PlaidCloud Conversão
Tableau Completo Publish to Tableau Escreve uma extração Hyper e publica-a na ligação Tableau associada.
Gem Estado Equivalente no PlaidCloud Conversão
Bedrock Completo Text NLP AI Incorpora a coluna de texto através da ligação de IA da área de trabalho.
OpenAI Completo Text NLP AI Responde a perguntas ou incorpora texto através da ligação de IA da área de trabalho.
Pinecone Lookup Completo Pedido REST Consulta o índice Pinecone para cada linha e acrescenta as colunas pinecone_matches e pinecone_error.
SageMaker Endpoint Completo Text NLP AI Responde a perguntas através da ligação de IA da área de trabalho.
Text Processing Completo Table Extract para divisão em blocos; Pedido REST para recolha de dados da Web A divisão em blocos torna-se uma expressão de blocos de carateres; a recolha de dados da Web obtém o URL de cada linha e junta o conteúdo da página de volta à linha.
Gem Estado Equivalente no PlaidCloud Conversão
Control Flow Input Completo Descartado (apenas marcador de limite) Descartado; apenas assinala o limite de entrada do subfluxo de trabalho do iterador.
Control Flow Output Completo Descartado (apenas marcador de limite) Descartado; apenas assinala o limite de saída do subfluxo de trabalho do iterador.
Subgraph (Basic) Completo Contentor da área de desenho / fluxo de trabalho aninhado a partir de processos em linha Converte o grafo interno em linha num fluxo de trabalho aninhado (ou em passos incorporados) com parâmetros de tabela de entrada/saída.
Table Iterator Completo Workflow Loop Executa o corpo do ciclo uma vez por linha de entrada, definindo cada valor de configuração a partir da respetiva coluna, até maxIteration.
While Iterator Completo Workflow Loop Executa o corpo do ciclo uma vez por passagem, transmitindo o número da iteração, até o corpo não devolver linhas ou o máximo da gem ser atingido.
Gem Estado Equivalente no PlaidCloud Conversão
External table Source/Target (BigQuery, Databricks, SAP HANA, MongoDB, MSSQL, Oracle, Postgres, Redshift, Salesforce, Snowflake, Synapse) Completo Passo de importação/exportação de dados externos com a ligação de base de dados correspondente Lê ou escreve uma tabela numa base de dados externa através de uma ligação do PlaidCloud.
File storage Source/Target (ADLS, Databricks Volumes, GCS, OneDrive, S3, SFTP, SharePoint, Smartsheet) Completo Passos de importação/exportação de ficheiros numa conta de documentos (ADLS/GCS/S3/SFTP/SharePoint/OneDrive) Lê ou escreve ficheiros em armazenamento na nuvem/SFTP com união por carateres universais, acionador, eliminação/movimentação e opções de encriptação.
Model Completo Tabela de saída do passo a montante Lê outro modelo como a tabela produzida pelo passo a montante referenciado.
Seed Completo Importar: CSV O CSV de seed é importado para uma tabela do PlaidCloud.
Source Completo Passo de importação escolhido pelo formato do conjunto de dados (consulte Conectores) Cada Source torna-se um passo de importação para uma tabela com o nome do conjunto de dados; um formato que o conversor não reconhece é lido como um ficheiro CSV carregado para a pasta de documentos do fluxo de trabalho, com um aviso.
Target Model / Table (Target) Completo Table Extract, Upsert, Copiar tabela e União total Escreve a seleção final do modelo numa tabela do PlaidCloud como substituição, acréscimo, upsert, eliminação e inserção, SCD2 ou substituição por predicado.
Upload Files Completo Importar: CSV Os ficheiros locais carregados tornam-se uma tabela através de um passo de importação.
Gem Estado Equivalente no PlaidCloud Conversão
Data Cleansing Completo Expressões de coluna num passo Table Extract Converte as opções de preenchimento de nulos, remoção de espaços e capitalização em expressões de coluna; as colunas limpas passam para o fim.
Data Masking Completo Expressões de coluna para mascaramento de carateres ou hash Mascara ou aplica hash às colunas de texto selecionadas no local ou como colunas novas.
Find Duplicates Completo Expressão de janela de número de linha mais filtro Devolve as linhas únicas, duplicadas ou selecionadas por contagem/posição, por chave.
Generate Rows Completo Tabela de sequência associada e filtrada por linha de entrada Gera linhas por linha de entrada a partir das expressões de inicialização, condição e ciclo.
Imputation Completo Agregação mais reassociação e expressão de coluna Substitui nulos ou valores sentinela pela média, mediana, moda ou um valor fixo.
Multi-Column Edit Completo Expressões por coluna expandidas a partir do modelo Aplica um modelo de expressão a todas as colunas selecionadas.
Multi-Column Rename Completo Mapeamento de mudança de nome de colunas num passo de seleção Muda o nome das colunas selecionadas por prefixo, sufixo ou expressão de nome.
Record ID Completo Expressão de coluna de número de linha ou uuid Acrescenta uma coluna de ID de registo UUID ou sequencial.
Sample Completo Limite de linhas ou opção de amostra na extração Toma as primeiras/últimas/aleatórias/N-ésimas/percentagem de linhas no total ou por grupo.
Tile Completo Expressões de janela para o número do escalão e a sequência Atribui números de escalão por soma igual, contagem, bandas de desvio-padrão, valores distintos ou limites manuais.
Gem Estado Equivalente no PlaidCloud Conversão
Aggregate Completo Table Extract com agregação; Pivot quando a gem faz pivô Agrupa e agrega, aplica a condição HAVING e faz o pivô para uma coluna por valor de pivô; propagate-all transporta todas as outras colunas de entrada.
Count Records Completo Passo de agregação com funções de contagem Devolve contagens totais, não nulas ou distintas numa linha.
Data Encoder/Decoder Completo Expressões de coluna para codificação e descodificação base64/hex Codifica ou descodifica as colunas selecionadas; AES apenas no Databricks.
Deduplicate Completo Table Extract com distinct ou um filtro de número de linha Mantém uma linha por chave: distinct, a primeira ou a última segundo a sua ordem de ordenação, qualquer uma, ou apenas as chaves que ocorrem uma vez.
Dynamic Select Completo Seleção de colunas num passo Table Extract resolvida por tipo Resolve as colunas por tipo no momento da conversão numa seleção explícita.
Filter Completo Table Extract com uma expressão de filtro Converte-se num passo Table Extract com uma expressão de filtro; as condições NULL eliminam a linha.
Finance Completo Expressão de coluna que implementa a função financeira Acrescenta o resultado de uma função financeira (FV, PV, NPV, IRR, …) como uma coluna nova.
Flatten Schema Completo Analisar JSON e Table Extract Aplana os campos aninhados em colunas com o nome formado pelo delimitador da gem e expande as matrizes numa linha por elemento.
Fuzzy Match Completo Table Extract e User Defined Transform Emparelha os registos, pontua cada campo de correspondência pelo método da gem, calcula a média das pontuações e mantém os pares iguais ou superiores ao seu limiar.
Limit Completo Table Extract com um limite de linhas Converte-se num limite de linhas; as referências de configuração tornam-se variáveis de projeto.
Order By Completo Ordenação num passo Table Extract Converte-se numa ordenação com as mesmas chaves, direção e posição dos nulos.
Pivot Completo Pivot Transforma os valores de pivô selecionados em colunas de agregações; uma lista de valores do modo Simple obtida em tempo de conceção é convertida como os valores listados.
Reformat Completo Table Extract com expressões de coluna Converte-se num passo Table Extract com uma expressão por coluna de saída; as colunas não listadas são eliminadas.
Running Total Completo Coluna de expressão de janela de soma cumulativa Acrescenta somas cumulativas por coluna selecionada.
Snowflake Unpivot (third-party) Completo Melt Desagrega colunas através de UNPIVOT do Snowflake.
Transpose Completo Melt Empilha colunas de dados em colunas de nome e de valor de texto.
TransposeAgg Completo Table Extract com agregação Converte o agrupamento, as agregações e o pivô da gem como um Aggregate, com um aviso para o rever.
Unpivot Completo Melt Empilha colunas de dados em colunas de nome e de valor.
Weighted Average Completo Passo de agregação com expressão de média ponderada Calcula uma média ponderada no total ou por grupo.
Window Function Completo Expressões de janela num passo Table Extract Acrescenta colunas de janela com a partição, a ordem e o quadro da gem, em linhas ou intervalo, com limites ilimitados, na linha atual ou com deslocamento.
Gem Estado Equivalente no PlaidCloud Conversão
Except Completo Anti-junção em todas as colunas mais um Table Extract distinct Mantém as linhas da primeira entrada que não aparecem em nenhuma das outras entradas.
Intersect Completo Junção interna em todas as colunas mais Distinct Mantém as linhas presentes em todas as entradas.
Join Completo Junção interna, Junção de várias tabelas, Anti-junção ou Junção cruzada Constrói a junção de cada tipo, interna, à esquerda, à direita, completa, semi, anti, cruzada e natural, com qualquer condição de junção, aplica a cláusula where e escreve a lista de seleção.
Union Completo União total Empilha as entradas por posição, removendo duplicados quando a gem não os mantém.
Union By Name Completo União total Torna-se uma União total que alinha as colunas por nome e preenche com nulos as que estão em falta.
Gem Estado Equivalente no PlaidCloud Conversão
JSON Parse Completo Analisar JSON Analisa uma coluna de texto JSON em campos estruturados.
Regex Completo Expressões regulares num passo Table Extract / Transform Substitui, analisa, faz corresponder ou segmenta uma coluna de texto com uma expressão regular.
Text To Columns Completo Passos de divisão de coluna / expansão com delimitador de expressão regular Divide uma coluna delimitada em colunas ou linhas usando um delimitador de expressão regular.
XML Parse Completo Análise de XML Analisa uma coluna de texto XML em campos estruturados.
Gem Estado Equivalente no PlaidCloud Conversão
Directory Completo Listagem de diretório Lista os ficheiros da pasta de documentos associada nas colunas da gem; com a opção de nome da folha, cada livro produz uma linha por folha. Uma pasta em falta produz zero linhas.
DynamicInput Completo Passo SQL para modelos de consulta; ciclo de fluxo de trabalho para o modo de vários ficheiros O modo de modelo de consulta incorpora o modelo como um passo SQL; o modo de vários ficheiros é mapeado com pressupostos.
Email Completo Notify Via Email Envia a mensagem de correio eletrónico, com um anexo de dados opcional, através de uma ligação de correio eletrónico associada.
RestAPI Completo Pedido REST Envia um pedido por linha de entrada com o seu URL, cabeçalhos, consulta, corpo e novas tentativas, guarda a resposta e consulta periodicamente um pedido assíncrono até estar concluído. As credenciais provêm da ligação que associar.
Script Completo Passo Python com reescrita do acesso a frames Incorpora o corpo do script num passo Python, com o acesso a data frames reescrito; os corpos em Scala são mantidos com uma nota.
SQL Statement Completo Passo SQL por separador de saída, com o texto traduzido para o dialeto do inquilino Incorpora cada separador como um passo SQL com as entradas associadas como tabelas temporárias; traduzido para o dialeto do inquilino.
StoredProcedure Completo Agent Remote Execution of SQL Chama o procedimento no respetivo armazém através da ligação que escolher: uma vez por linha de entrada, com cada argumento associado a partir da sua coluna, ou uma vez quando não recebe argumentos. As colunas de entrada passam sem alterações.
Table Operations Completo Table In-Place Delete, Table Update, Table Drop Atualizar, eliminar e remover correspondem a passos de tabela; vacuum e otimizar tornam-se otimização de tabela ou uma operação nula, com um aviso.
ToDo Completo Gerar erro de fluxo de trabalho ou Notify via Log Assinala lógica ainda por escrever: uma mensagem de registo quando nada a lê, ou um passo que pára a execução com a mensagem da gem quando um passo posterior depende dela.
Gem Estado Equivalente no PlaidCloud Conversão
Buffer Completo Spatial Buffer Aumenta cada geometria na distância configurada, em milhas ou quilómetros.
CreatePoint Completo Table Extract com geom_point Constrói geometria de pontos a partir de colunas de longitude e latitude.
Distance Completo Table Extract Calcula a distância, a direção cardinal e o rumo entre dois pontos WKT.
FindNearest Completo Table Extract com uma junção cruzada Encontra os N pontos de destino mais próximos de cada ponto de origem dentro de uma distância máxima.
HeatMap Completo Heat Map (macro) Agrupa pontos em hexágonos H3 na resolução da gem, distribui o calor pela distância da grelha com a respetiva atenuação e indica a densidade e o contorno de cada hexágono.
PolyBuild Completo Table Extract e um passo Python Constrói WKT de polígonos ou polilinhas a partir de pontos ordenados por grupo.
Simplify Completo Spatial Generalize Simplifica geometrias WKT por uma tolerância em milhas/quilómetros.
SpatialMatch Completo Correspondência espacial Faz corresponder geometrias de origem e de destino por interseção/contenção/pertença/toque/envelope.
Gem Estado Equivalente no PlaidCloud Conversão
PowerBIWrite Completo Pedido REST Cria o conjunto de dados do Power BI e envia as linhas através da API REST do Power BI.
TableauWrite Completo Publish to Tableau Escreve uma extração Hyper e publica-a na ligação Tableau associada.
Visualize Completo Copiar tabela Transmite as linhas sem alterações; crie o gráfico como um painel de controlo do PlaidCloud sobre a mesma tabela.
Gem Estado Equivalente no PlaidCloud Conversão
Condition Completo Junção cruzada e Table Extract Avalia as condições sobre toda a entrada e envia cada linha para a primeira saída cuja condição se verifica, ou para a última saída caso contrário.
Macro Completo Passo SQL com o corpo da macro expandido Incorpora o corpo da macro como um passo SQL traduzido para o dialeto do inquilino, com as entradas associadas como tabelas temporárias.
Pipeline (trigger) Completo Workflow Loop Executa o pipeline indicado uma vez por linha de entrada com os seus parâmetros e condição de acionamento, continua após uma execução falhada e devolve uma linha por execução.
Subgraph (Basic) Completo Contentor da área de desenho / fluxo de trabalho aninhado a partir de processos em linha Converte o grafo interno em linha num fluxo de trabalho aninhado (ou em passos incorporados) com parâmetros de tabela de entrada/saída.

Os formatos de conjuntos de dados e os conectores são definições de origem e de destino de uma gem, não gems. Cada formato é convertido no passo de importação ou exportação indicado, e a conversão nunca contacta o sistema de origem ou de destino.

Formato Estado Equivalente no PlaidCloud Conversão
Avro Completo Importar: Avro; Exportar: Avro Lê e escreve ficheiros Avro.
BigQuery Completo Ligação a base de dados externa com importação de tabela Lê e escreve através de uma ligação.
Binary files Completo Listagem de diretório com o conteúdo dos ficheiros; Executor Alteryx para escrever Lê cada ficheiro da pasta com o respetivo caminho, hora de modificação, tamanho e conteúdo; escreve o conteúdo de cada linha no ficheiro indicado pelo respetivo caminho.
Catalog table Completo Associação a tabela existente do PlaidCloud Associa-se a uma tabela por nome; a leitura e todos os modos de escrita são convertidos.
Cosmos DB Completo Importação e exportação: Pedido REST Lê e escreve os documentos do contentor através da sua ligação ao Cosmos DB.
CSV Completo Importar: CSV; Exportar: CSV Lê e escreve ficheiros delimitados com opções de cabeçalho, separador, aspas, escape e codificação.
Data Generator Completo Table Faker Gera as colunas do conjunto de dados com os mesmos tipos de dados fictícios.
DataHub table Completo Importar SQL Lê a tabela indicada pelo conjunto de dados através da sua ligação; uma escrita é guardada numa tabela do PlaidCloud.
Delta Completo Associação a tabela existente do PlaidCloud Lê e escreve a tabela em todos os modos de escrita; a leitura de uma versão anterior é feita através da ligação Databricks que associar.
Excel (XLSX) Completo Importar: Excel; Exportar: Excel Lê e escreve folhas e intervalos de livros.
Fixed format Completo Importar: Largura fixa; Exportar: CSV Lê ficheiros de largura fixa dispostos segundo as larguras de coluna do conjunto de dados; escreve um ficheiro delimitado.
Hive Completo Importar: SQL; Exportar: Tabelas externas Lê e escreve a tabela através da sua ligação ao Hive.
Iceberg Completo Associação a tabela existente do PlaidCloud Lê e escreve a tabela.
JDBC Completo Ligação a base de dados externa com importação de tabela Lê uma tabela ou consulta e escreve em modo de substituição ou acréscimo através da sua ligação; uma instrução posterior à escrita é executada depois da escrita.
JSON Completo Analisar JSON Carrega registos e aplana os campos aninhados.
Kafka Completo Importar: Kafka; Exportar: Kafka Lê um tópico como um único lote de mensagens e escreve as linhas como mensagens.
MongoDB Completo Importar: MongoDB; Exportar: MongoDB Lê e escreve a coleção através da sua ligação ao MongoDB.
ORC Completo Importar: ORC; Exportar: ORC Lê e escreve ficheiros ORC.
Parquet Completo Importar: Parquet; Exportar: Parquet Lê e escreve ficheiros Parquet.
Pinecone Completo Importação e exportação: Pedido REST Lê os registos de um índice e faz upsert das linhas como vetores através da API REST do Pinecone.
Redshift Completo Ligação a base de dados externa com importação de tabela Lê e escreve através de uma ligação.
Salesforce Completo Importar: Salesforce: Consultar objeto; Exportar: Pedido REST Lê um objeto ou uma consulta SOQL e escreve registos através da sua ligação ao Salesforce.
Seed (inline) Completo Importar: CSV Carrega as linhas em linha como uma tabela.
Slack Completo Importar: Singer; Exportar: Pedido REST Lê as mensagens de um canal e publica cada linha como uma mensagem através da sua ligação ao Slack.
Smartsheet Completo Importação e exportação: Pedido REST Lê e escreve as linhas da folha através da sua ligação ao Smartsheet.
Snowflake Completo Ligação a base de dados externa com importação de tabela Lê e escreve através de uma ligação.
SQL file types (CSV, Excel, JSON, Parquet, Text, XML, fixed-width) Completo Passos de importação e exportação de ficheiros numa conta de documentos Lê e escreve o tipo de ficheiro; as opções sem equivalente no PlaidCloud são assinaladas.
Text Completo Importar: CSV como uma única coluna Lê cada linha como uma coluna.
Web page Completo Pedido REST Lê a página do URL do conjunto de dados para uma tabela.
XML Completo Análise de XML Carrega registos pela etiqueta de linha.
Área Estado Equivalente no PlaidCloud Conversão
Expressões Completo Expressões SQL de Spark e de armazém traduzidas função a função As funções e os operadores são convertidos em expressões do PlaidCloud; uma função sem equivalente é assinalada pelo nome.
Estrutura do projeto e do grafo Completo Carregador de projetos Todos os formatos de exportação do Prophecy são carregados e normalizados num único modelo.
Caso O que acontece
Código ou dados que a exportação não inclui Uma Gem Builder ou outra gem personalizada cujo código não está na exportação, e uma chamada a uma macro de um pacote dbt que a exportação deixa de fora, tornam-se um passo que indica o que falta; exporte o projeto com o código do pipeline e os pacotes dbt, ou reconstrua a lógica num passo Python ou SQL. As gems Ab Initio Error Detection e MTime transmitem a sua entrada sem alterações, porque a regra que aplicam não está na exportação. As verificações Soda lidas de um ficheiro fora do projeto, e as verificações Soda que comparam com análises anteriores ou com outro conjunto de dados, ou que testam um formato que o Soda indica, não têm linha na tabela de resultados; calcule-as num passo posterior.
Resultados que só se conhecem quando o pipeline é executado Uma gem REST API que aplana a sua resposta coloca a resposta inteira numa única coluna quando nada declara os nomes dos campos, o que só uma execução revela; extraia os campos de que precisa num passo posterior. Uma macro dbt que consulta o armazém à medida que o dbt compila torna-se um passo que a indica; substitua a consulta pelos valores que devolve. Uma gem StoredProcedure do Spark é executada, mas os seus valores OUT não são devolvidos; a saída são as colunas transmitidas. input_file_name() devolve uma cadeia vazia sobre uma origem de tabela ou Delta, que não tem ficheiro para nomear, e hash() / xxhash64() dentro de uma agregação, uma janela ou uma gem com várias entradas são calculados pelo armazém, pelo que podem diferir dos do Spark.
Valores escritos num passo quando o projeto é convertido Um valor de parâmetro que contenha aspas, barra invertida ou chaveta, um valor de pipeline lido por um passo SQL e a base de dados que uma operação de tabela Delta indica através da configuração são escritos no passo como valores fixos, pelo que alterar a variável do fluxo de trabalho não os altera; edite o passo quando a configuração mudar.
Código Scala Um script Scala, uma expressão Scala ou uma função definida pelo utilizador ou função de agregação em Scala torna-se um passo que a indica; reescreva-a em SQL ou Python.
Início de sessão Kerberos do Kafka Um source ou target Kafka que inicia sessão com Kerberos (GSSAPI) é convertido sem o nome do serviço Kerberos nem o mecanismo de início de sessão; defina-os na ligação do PlaidCloud.
Streaming Os sources, targets e pipelines de streaming são executados como fluxos de trabalho em lote sobre os dados presentes quando são executados; agende o fluxo de trabalho para ser executado com a frequência de que necessitar.
Componentes de tarefas Uma tarefa Spark é convertida com o seu único pipeline e agendamento; os seus outros componentes, condições de execução e substituições de configuração não são convertidos.
Chamadas pouco comuns Uma função de agregação definida pelo utilizador chamada a partir de um rollup ou de uma janela, e uma macro dbt que usa Jinja além de if, for, set e dos filtros comuns, tornam-se um passo que indica a gem; chame a função a partir de uma gem Aggregate ou incorpore a macro.

Compare a saída do fluxo de trabalho convertido com a saída do seu próprio pipeline do Prophecy: esquema, contagem de linhas e valores das linhas. Ignore a ordem das linhas, a menos que o fluxo de trabalho dependa dela.