DE

✅ Azure Stream Analytics ✅ Fabric Eventstream

Especifica o fluxo de entrada ou um nome de etapa associado em uma cláusula COM. A cláusula FROM é sempre necessária para qualquer instrução SELECT.

Sintaxe

FROM <input_source> [<PARTITION BY clause>] [<TIMESTAMP BY clause>]
  
<PARTITION BY clause> ::== PARTITION BY <key_spec>

<TIMESTAMP BY clause> ::== TIMESTAMP BY scalar_expression [OVER <key_spec>]

<input_source> ::=   
    {   
      *   
      | { input_name |  input_alias }.*   
      | {  
          [ { input_name | input_alias }. ]  
               { column_name }  
     | expression [ [ AS ] column_alias ]  
         }  
      | column_alias = expression   
    }

<key_spec> ::== { column_name | expression } [,... n]

Argumentos

*

Especifica que todas as colunas de todos os fluxos de entrada na cláusula FROM devem ser retornadas. As colunas são retornadas pela fonte de entrada, conforme especificado na cláusula FROM e na ordem em que existem no fluxo de entrada.

input_name | input_alias.*

Limita o escopo do * ao nome de entrada especificado.

column_name

É o nome de uma coluna a ser retornada. Qualifique column_name para evitar uma referência ambígua, como ocorre quando duas fontes de entrada na cláusula FROM têm colunas com nomes duplicados.

expressão

É uma constante, função, qualquer combinação de nomes de coluna, constantes e funções conectadas por um operador ou operadores, ou uma subconsulta.

Column_alias

É um nome alternativo para substituir o nome da coluna no conjunto de resultados da consulta. Por exemplo, um alias como Quantity, ou Quantity to Date, ou Qty pode ser especificado para uma coluna chamada quantity. Os aliases também são usados para especificar nomes para os resultados das expressões. column_alias não pode ser usado em uma cláusula WHERE, GROUP BY ou HAVENDO.

PARTITON POR <key_spec>

Particiona dados em subconjuntos com base em <key_spec>. Isso permite que o trabalho consuma e escreva diferentes partições em paralelo. Para obter mais informações, veja Leverage query parallelization in Azure Stream Analytics (Tirar partido da paralelização de consultas no Azure Stream Analytics).

CARIMBO DE DATA/HORA POR scalar_expression [MAIS DE <key_spec>]

Permite que os eventos sejam marcados com a hora por scalar_expression em vez da hora de chegada. A cláusula OVER pode ser usada para criar cronogramas independentes para cada chave distinta. Para obter mais informações, consulte a documentação em TIMESTAMP BY.

Exemplo

SELECT TollId, EntryTime AS VehicleEntryTime, LicensePlate, State, Make, Model, VehicleType, VehicleWeight, Toll, Tag   
FROM TollTagEntry TIMESTAMP BY EntryTime