FROM (Azure Stream Analytics)

WITH 句で関連付けられている入力ストリームまたはステップ名を指定します。 FROM 句は、すべての SELECT ステートメントに対して常に必要です。

構文

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]

引数

*

FROM 句のすべての入力ストリームからすべての列を返す必要があることを指定します。 列は、FROM 句で指定されている入力ストリームによって、受信ストリームと同じ順序で返されます。

input_name | input_alias.*

* の範囲を指定した入力名に制限します。

column_name

返される列の名前です。 column_name で修飾することにより、FROM 句の 2 つの入力ソースに重複する名前の列があるような場合に発生する、あいまいな参照を防ぎます。

式 (expression)

定数、関数、または列名、定数、関数を演算子で組み合わせたもの、あるいはサブクエリを指定します。

Column_alias

クエリの結果セット内の列名を置き換える別名です。 たとえば、quantity という名前の列に対して、Quantity、Quantity to Date、Qty などの別名を指定できます。 別名は、式の結果の名前を指定するためにも使用されます。 where 句、GROUP BY 句、HAVING 句では、column_aliasを使用できません。

PARTITON BY <key_spec>

key_specに基づいてデータをサブセットに<パーティション分割します。> これにより、ジョブは異なるパーティションを並列で使用および書き込むことができます。 詳細については、「Azure Stream Analytics でのクエリの並列処理の活用」を参照してください。

TIMESTAMP BY scalar_expression [OVER <key_spec>]

イベントを到着時刻ではなく scalar_expression でタイムスタンプ付けできるようにします。 OVER 句を使用すると、個別のキーごとに独立したタイムラインを作成できます。 詳細については、 TIMESTAMP BY に関するドキュメントを参照してください。

例

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