FROM (Azure Stream Analytics)

Especifica o fluxo de entrada ou um nome de passo associado numa cláusula WITH. 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 devolvidas. As colunas são devolvidas pela origem de entrada, conforme especificado na cláusula FROM, e pela ordem em que existem no fluxo de entrada.

input_name | input_alias.*

Limita o âmbito do * ao nome de entrada especificado.

column_name

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

expression

É uma constante, função, qualquer combinação de nomes de colunas, constantes e funções ligadas por um operador ou operador, 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 Quantidade, Quantidade até Data ou Qty pode ser especificado para uma coluna denominada quantidade. Os aliases também são utilizados para especificar nomes para os resultados das expressões. column_alias não pode ser utilizado numa cláusula WHERE, GROUP BY ou HAVING.

PARTITON BY <key_spec>

Cria partições de dados em subconjuntos com base em <key_spec>. Isto permite que a tarefa consuma e escreva partições diferentes 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).

TIMESTAMP BY scalar_expression [OVER <key_spec>]

Permite que os eventos sejam carimbos de data/hora por scalar_expression em vez da hora de chegada. A cláusula OVER pode ser utilizada para criar linhas cronológicas independentes para cada chave distinta. Para obter mais informações, veja a documentação sobre TIMESTAMP BY.

Exemplo

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