VON

✅ Azure Stream Analytics ✅ Fabric Eventstream

Gibt den Eingabedatenstrom oder einen Schrittnamen an, der einer WITH-Klausel zugeordnet ist. 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

*

Gibt an, dass alle Spalten aus allen Eingabedatenströmen in der FROM-Klausel zurückgegeben werden sollen. Die Spalten werden von der Eingabequelle zurückgegeben, wie in der FROM-Klausel angegeben, und in der Reihenfolge, in der sie im eingehenden Datenstrom vorhanden sind.

input_name | input_alias.*

Beschränkt den Bereich des * auf den angegebenen Eingabenamen.

column_name

Ist der Name einer Spalte, die zurückgegeben werden soll. Qualifizieren Sie column_name, um einen mehrdeutigen Verweis zu verhindern, z. B. wenn zwei Eingabequellen in der FROM-Klausel Spalten mit doppelten Namen aufweisen.

Ausdruck

Ist eine Konstante, Funktion, eine beliebige Kombination aus Spaltennamen, Konstanten und Funktionen, die von einem Operator oder Operator oder einer Unterabfrage verbunden sind.

Column_alias

Ist ein alternativer Name, um den Spaltennamen im Abfrageergebnissatz zu ersetzen. Beispielsweise kann ein Alias wie "Menge" oder "Menge bis Datum" oder "Qty" für eine Spalte mit dem Namen "Menge" 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 [OVER <key_spec>]

Ermöglicht die Zeitstempelung von Ereignissen durch scalar_expression anstelle der Ankunftszeit. Die OVER-Klausel kann verwendet werden, um unabhängige Zeitachsen für jeden eindeutigen 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