DE

✅ Azure Stream Analytics ✅ Fabric Eventstream

Spécifie le flux d’entrée ou un nom d’étape associé à une clause WITH. La clause FROM est toujours obligatoire 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]

Les arguments

*

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

input_name | input_alias.*

Limite l’étendue du * au nom d’entrée spécifié.

column_name

Nom d’une colonne à retourner. Qualifiez column_name pour empêcher une référence ambiguë, par exemple lorsque deux sources d’entrée dans la clause FROM ont des colonnes avec des noms en double.

expression

Est une constante, une fonction, une combinaison de noms de colonnes, de constantes et de fonctions connectées par un opérateur ou un opérateur ou une sous-requête.

Column_alias

Nom alternatif pour remplacer le nom de colonne dans le jeu de résultats de la requête. Par exemple, un alias tel que Quantity, or Quantity to Date, ou Qty peut être spécifié pour une colonne nommée quantity. 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