INTO (Azure Stream Analytics)
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".
[ INTO <output_stream> ]
output_stream
Especifica el nombre de un flujo de salida.
No puede usar SELECT ... INTO en una cláusula WITH. Por ejemplo, la cláusula INTO solo se puede usar en la subconsulta exterior.
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 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.
[ INTO <shard_count> ]
shard_count
Especifica el número de particiones en el paso ascendente.
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.
WITH Step1 AS (
SELECT *
FROM input
PARTITION BY DeviceId
INTO 10
)
SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId