ОТ

✅ Поток событий Azure Stream Analytics ✅ Fabric

Указывает входной поток или имя шага, связанное с предложением 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 имеют столбцы с повторяющимися именами.

выражение

Является константой, функцией, любой комбинацией имен столбцов, констант и функций, подключенных оператором или операторами, или вложенным запросом.

Column_alias

Альтернативное имя для замены имени столбца в результирующем наборе запросов. Например, псевдоним, например "Количество" или "Количество до даты", или "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