✅ Azure 串流分析 ✅ 網狀架構事件串流
指定WITH子句中相關聯的輸入數據流或步驟名稱。 任何 SELECT 陳述式一律需要 FROM 子句。
語法
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子句中的兩個輸入來源具有重複名稱的數據行時發生。
表示式
這是常數、函式、由運算符或運算子或子查詢連接之數據行名稱、常數和函式的任何組合。
Column_alias
這是取代查詢結果集中數據行名稱的替代名稱。 例如,可以針對名為 quantity 的數據行指定別名,或 Quantity to Date 或 Qty 等別名。 別名也可用來指定表示式結果的名稱。 column_alias不能用於 WHERE、GROUP BY 或 HAVING 子句。
PARTITON BY <key_spec>
根據 <key_spec>將數據分割成子集。 這可讓作業以平行方式取用和寫入不同的分割區。 如需詳細資訊,請參閱利用 Azure 串流分析中的查詢平行化作業。
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