FROM (Azure Stream Analytics)

Hiermee geeft u de invoerstroom of een stapnaam op die is gekoppeld aan een WITH-component. De FROM-component is altijd vereist voor een 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 de invoerbron, zoals opgegeven in de FROM-component, en in de volgorde waarin ze zich in de binnenkomende stroom bevinden.

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. Kwalificeren column_name om een dubbelzinnige verwijzing te voorkomen, zoals wanneer twee invoerbronnen in de FROM-component kolommen met dubbele namen hebben.

expression

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

Column_alias

Is een alternatieve naam ter vervanging van de kolomnaam in de queryresultatenset. U kunt bijvoorbeeld een alias zoals Hoeveelheid, Hoeveelheid tot datum of Kwantiteit opgeven voor een kolom met de naam quantity. 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 voorzien van een tijdstempel op scalar_expression in plaats van de aankomsttijd. De OVER-component kan worden gebruikt om onafhankelijke tijdlijnen te maken 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