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 имеют столбцы с одинаковыми именами.
expression
Является константой, функцией, любым сочетанием имен столбцов, констант и функций, соединенных оператором (операторами) или вложенным запросом.
Column_alias
Альтернативное имя, которым можно заменить имя столбца в результирующем наборе запроса. Например, для столбца «quantity» может быть указан псевдоним «Quantity», «Quantity to Date» или «Qty». Псевдонимы также используются для указания имен для результатов выражений. 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