INTO (Azure Stream Analytics)

INTO (flujo de salida)

INTO especifica explícitamente un flujo de salida y siempre está asociado a una expresión SELECT. Si no se especifica, el flujo de salida predeterminado es "salida".

Sintaxis

[ INTO <output_stream> ]  

Argumentos

output_stream

Especifica el nombre de un flujo de salida.

Limitaciones y restricciones

No puede usar SELECT ... INTO en una cláusula WITH. Por ejemplo, la cláusula INTO solo se puede usar en la subconsulta exterior.

Ejemplo

WITH WAVehicle AS (  
    SELECT TollId, EntryTime AS VehicleEntryTime, LicensePlate, State, Make, Model, VehicleType,    VehicleWeight, Toll, Tag  
    FROM TollTagEntry TIMESTAMP BY EntryTime  
    WHERE State = "WA"
)  
  
SELECT * INTO WAVehicleArchive FROM WAVehicle;  
  
SELECT DateAdd(minute,-3,System.Timestamp()) AS WinStartTime, System.Timestamp() AS WinEndTime, COUNT(*) INTO WAVehicleCount FROM WAVehicle GROUP BY TumblingWindow(minute, 3)  
  

INTO (recuento de particiones)

INTO especifica explícitamente el número de particiones en un paso de entrada al especificar un esquema de partición (PARTITION BY). Si no se especifica el recuento de particiones, el número de particiones se transfiere si PARTITION BY es el mismo o dos de lo contrario.

INTO es una sugerencia para el sistema y puede omitirse si el sistema determina que la especificación explícita no es beneficiosa.

Sintaxis INTO

[ INTO <shard_count> ]  

Argumentos INTO

shard_count

Especifica el número de particiones en el paso ascendente.

Limitaciones y restricciones into

El recuento de particiones debe ser mayor que 1. Al unir varias secuencias, el recuento de particiones de todas las entradas debe ser el mismo.

Ejemplo INTO

WITH Step1 AS (
    SELECT * 
    FROM input 
    PARTITION BY DeviceId
    INTO 10
)

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId