FROM (Azure Stream Analytics)

Spécifie le flux d'entrée ou un nom d'étape associé dans une clause WITH. La clause FROM est toujours requise pour toute instruction SELECT.

Syntaxe

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]

Arguments

*

Spécifie que toutes les colonnes de tous les flux entrants dans la clause FROM doivent être renvoyées. Les colonnes sont renvoyées par la source d'entrée, comme spécifié dans la clause FROM, et dans l'ordre dans lequel elles figurent dans le flux entrant.

input_name | input_alias.*

Limite l'étendue de * au nom d'entrée spécifié.

column_name

Nom d'une colonne à renvoyer. Qualifiez column_name pour éviter une référence ambiguë, comme cela se produit quand deux sources d'entrée dans la clause FROM possèdent des colonnes avec des noms dupliqués.

expression

Constante, fonction ou toute combinaison de noms de colonne, de constantes et de fonctions reliées par un ou plusieurs opérateurs, ou par une sous-requête.

Column_alias

Nom utilisé pour remplacer le nom de colonne dans le jeu de résultats de la requête. Par exemple, vous pouvez spécifier un alias tel que Quantité, Quantité à la date du jour ou Qté pour une colonne appelée quantité. Les alias sont également utilisés pour spécifier des noms pour les résultats des expressions. column_alias ne peut pas être utilisé dans une clause WHERE, GROUP BY ou HAVING.

PARTITON BY <key_spec>

Partitionne les données en sous-ensembles en fonction <de key_spec>. Cela permet au travail de consommer et d’écrire différentes partitions en parallèle. Pour plus d’informations, consultez Profiter de la parallélisation de requête dans Azure Stream Analytics.

TIMESTAMP BY scalar_expression [OVER <key_spec>]

Permet aux événements d’être horodatés par scalar_expression au lieu de l’heure d’arrivée. La clause OVER peut être utilisée pour créer des chronologies indépendantes pour chaque clé distincte. Pour plus d’informations, consultez la documentation sur TIMESTAMP BY.

Exemple

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