FROM (Azure Stream Analytics)

Anger indataströmmen eller ett stegnamn som är associerat med en WITH-sats. FROM-satsen krävs alltid för valfri SELECT-instruktion.

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]

Argument

*

Anger att alla kolumner från alla indataströmmar i FROM-satsen ska returneras. Kolumnerna returneras av indatakällan, enligt vad som anges i FROM-satsen, och i den ordning de finns i den inkommande dataströmmen.

input_name | input_alias.*

Begränsar omfattningen för * till det angivna indatanamnet.

column_name

Är namnet på en kolumn som ska returneras. Kvalificera column_name för att förhindra en tvetydig referens, till exempel när två indatakällor i FROM-satsen har kolumner med dubblettnamn.

expression

Är en konstant, funktion, en kombination av kolumnnamn, konstanter och funktioner som är anslutna av en operator eller operator eller en underfråga.

Column_alias

Är ett alternativt namn för att ersätta kolumnnamnet i frågeresultatuppsättningen. Till exempel kan ett alias, till exempel Kvantitet eller Kvantitet till datum, eller Qty anges för en kolumn med namnet quantity. Alias används också för att ange namn för resultatet av uttryck. column_alias kan inte användas i en WHERE-, GROUP BY- eller HAVING-sats.

PARTITON EFTER <key_spec>

Partitioner data i delmängder baserat på <key_spec>. På så sätt kan jobbet använda och skriva olika partitioner parallellt. Mer information finns i Utnyttja frågeparallellisering i Azure Stream Analytics.

TIDSSTÄMPEL EFTER scalar_expression [ÖVER <key_spec>]

Tillåter att händelser tidsstämplas av scalar_expression i stället för ankomsttid. OVER-satsen kan användas för att skapa oberoende tidslinjer för varje distinkt nyckel. Mer information finns i dokumentationen om TIMESTAMP BY.

Exempel

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