VAN

✅ Azure Stream Analytics ✅ Fabric Eventstream

Hiermee geeft u de invoerstroom of een stapnaam op die is gekoppeld aan een WITH-component. De FROM-component is altijd vereist voor elke SELECT-instructie.

Syntaxis

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]

Argumenten

*

Hiermee geeft u op dat alle kolommen van alle invoerstromen in de FROM-component moeten worden geretourneerd. De kolommen worden geretourneerd door invoerbron, zoals opgegeven in de FROM-component, en in de volgorde waarin ze aanwezig zijn in de binnenkomende stroom.

input_name | input_alias.*

Beperkt het bereik van de * tot de opgegeven invoernaam.

column_name

Is de naam van een kolom die moet worden geretourneerd. In aanmerking komen column_name om te voorkomen dat een dubbelzinnige verwijzing wordt gebruikt, zoals wanneer twee invoerbron in de FROM-component kolommen met dubbele namen bevat.

expressie

Is een constante, functie, elke combinatie van kolomnamen, constanten en functies die zijn verbonden door een operator of operator of een subquery.

Column_alias

Is een alternatieve naam om de kolomnaam in de queryresultatenset te vervangen. U kunt bijvoorbeeld een alias, zoals Quantity, of Quantity to Date, of Qty opgeven voor een kolom met de naam aantal. Aliassen worden ook gebruikt om namen op te geven voor de resultaten van expressies. column_alias kan niet worden gebruikt in een WHERE-, GROUP BY- of HAVING-component.

PARTITON BY <key_spec>

Partitioneert gegevens in subsets op <basis van key_spec>. Hierdoor kan de taak verschillende partities parallel gebruiken en schrijven. Zie Query-parallellisatie gebruiken in Azure Stream Analytics voor meer informatie.

TIMESTAMP BY scalar_expression [OVER <key_spec>]

Hiermee kunnen gebeurtenissen worden ingestempeld door scalar_expression in plaats van de aankomsttijd. De OVER-component kan worden gebruikt voor het maken van onafhankelijke tijdlijnen voor elke afzonderlijke sleutel. Zie de documentatie over TIMESTAMP BY voor meer informatie.

Voorbeeld

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