FROM (Azure Stream Analytics)

Especifica el flujo de entrada o un nombre de paso asociado en una cláusula WITH. La cláusula FROM siempre se requiere en cualquier instrucción SELECT.

Sintaxis

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]

Argumentos

*

Especifica que se deben devolver todas las columnas de todos los flujos de entrada en la cláusula FROM. Las columnas se devuelven por origen de entrada, según lo especificado en la cláusula FROM, y en el orden en que existen en la transmisión entrante.

input_name | input_alias.*

Limita el ámbito del * al nombre de entrada especificado.

column_name

Es el nombre de una columna que se va a devolver. Califique column_name para evitar una referencia ambigua, como la que se produce cuando dos orígenes de entrada en la cláusula FROM tienen columnas con nombres duplicados.

expression

Es una constante, una función o una combinación de nombres de columna, constantes y funciones conectados mediante un operador, varios operadores o una subconsulta.

Column_alias

Es un nombre alternativo que se utiliza para reemplazar el nombre de la columna en el conjunto de resultados de la consulta. Por ejemplo, se puede especificar un alias como Quantity, Quantity to Date o Qty para una columna denominada quantity. Los alias también se usan para especificar nombres para los resultados de las expresiones. column_alias no se puede usar en una cláusula WHERE, GROUP BY o HAVING.

PARTITON BY <key_spec>

Divide los datos en subconjuntos basados en <key_spec>. Esto permite que el trabajo consuma y escriba particiones diferentes en paralelo. Para más información, consulte Aprovechamiento de la paralelización de consultas en Azure Stream Analytics.

TIMESTAMP BY scalar_expression [OVER <key_spec>]

Permite que los eventos estén registrados por scalar_expression en lugar de la hora de llegada. La cláusula OVER se puede usar para crear escalas de tiempo independientes para cada clave distinta. Para obtener más información, consulte la documentación sobre TIMESTAMP BY.

Ejemplo

SELECT TollId, EntryTime AS VehicleEntryTime, LicensePlate, State, Make, Model, VehicleType, VehicleWeight, Toll, Tag   
FROM TollTagEntry TIMESTAMP BY EntryTime