差出人

✅ Azure Stream Analytics ✅ Fabric Eventstream

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

返す列の名前を指定します。 FROM 句の 2 つの入力ソースに重複する名前の列がある場合など、あいまいな参照を防ぐために、column_nameを修飾します。

式

定数、関数、演算子または演算子、またはサブクエリによって接続された列名、定数、関数の任意の組み合わせです。

Column_alias

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

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