Поделиться через


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