FROM (Azure Stream Analytics)

Especifica o fluxo de entrada ou um nome de etapa associado em uma 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 retornadas. As colunas são retornadas por fonte de entrada, conforme especificado na cláusula FROM, e na ordem em que aparecem 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 impedir 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 Quantidade ou Quantidade até a Data ou Qtd pode ser especificado para uma coluna denominada quantidade. 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 HAVING.

PARTITON POR <key_spec>

Particiona dados em subconjuntos com base em <key_spec>. Isso permite que o trabalho consuma e escreva partições diferentes em paralelo. Para obter mais informações, confira Aproveitar a 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 usada para criar linhas do tempo independentes para cada chave distinta. Para obter mais informações, consulte 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