FROM (Azure Stream Analytics)

Gibt den Eingabestream oder einen einer WITH-Klausel zugeordneten Schrittnamen an. Die FROM-Klausel muss in einer SELECT-Anweisung immer angegeben werden.

Syntax

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]

Argumente

*

Legt fest, dass alle Spalten aller Eingabestreams in der FROM-Klausel zurückgegeben werden sollen. Die Spalten werden nach Eingabequelle (wie in der FROM-Klausel angegeben) und in der Reihenfolge, in der sie im eingehenden Stream vorkommen, zurückgegeben.

input_name | input_alias.*

Beschränkt den Umfang von * auf den angegebenen Eingabenamen.

column_name

Dies ist der Name einer Spalte, die zurückgegeben werden soll. Qualifizieren Sie "column_name", um eine mehrdeutige Referenz zu vermeiden, die z. B. auftritt, wenn zwei Eingabequellen in der FROM-Klausel Spalten mit demselben Namen enthalten.

expression

Eine Konstante, eine Funktion oder eine beliebige, durch einen oder mehrere Operatoren verknüpfte Kombination von Spaltennamen, Konstanten und Funktionen oder eine Unterabfrage.

Column_alias

Dies ist ein alternativer Name, der den Spaltennamen im Abfrageresultset ersetzt. Für eine Spalte mit dem Namen quantity könnte z. B. ein Alias wie Quantity, Quantity to Date oder Qty angegeben werden. Aliase werden auch verwendet, um Namen für die Ergebnisse von Ausdrücken anzugeben. column_alias können nicht in einer WHERE-, GROUP BY- oder HAVING-Klausel verwendet werden.

PARTITON BY <key_spec>

Partitioniert Daten basierend auf <key_spec> in Teilmengen. Dadurch kann der Auftrag verschiedene Partitionen parallel nutzen und schreiben. Weitere Informationen finden Sie unter Nutzen der Parallelisierung von Abfragen in Azure Stream Analytics.

TIMESTAMP BY scalar_expression [ÜBER <key_spec>]

Ermöglicht das Zeitstempeln von Ereignissen durch scalar_expression anstelle der Ankunftszeit. Die OVER-Klausel kann verwendet werden, um unabhängige Zeitachsen für jeden einzelnen Schlüssel zu erstellen. Weitere Informationen finden Sie in der Dokumentation zu TIMESTAMP BY.

Beispiel

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