INTO (Azure Stream Analytics)

INTO (strumień wyjściowy)

FUNKCJA INTO jawnie określa strumień wyjściowy i jest zawsze skojarzona z wyrażeniem SELECT. Jeśli nie zostanie określony, domyślny strumień wyjściowy to "output".

Składnia

[ INTO <output_stream> ]  

Argumenty

output_stream

Określa nazwę strumienia wyjściowego.

Ograniczenia i ograniczenia

Nie można użyć opcji SELECT ... INTO w klauzuli WITH. Na przykład klauzula INTO może być używana tylko w podquerii out-most.

Przykład

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 (liczba fragmentów)

INTO jawnie określa liczbę fragmentów w kroku wejściowym podczas określania schematu partycjonowania (PARTITION BY). Jeśli nie określono liczby partycji, liczba fragmentów jest przenoszona, jeśli partycja BY jest taka sama lub dwie w przeciwnym razie.

INTO to wskazówka dla systemu i może być ignorowana, jeśli system określi jawną specyfikację nie jest korzystne.

SKŁADNIA INTO

[ INTO <shard_count> ]  

INTO Argumenty

shard_count

Określa liczbę fragmentów w kroku nadrzędnym.

INTO Limitations and Restrictions

Liczba fragmentów musi być większa niż 1. Podczas łączenia kilku strumieni liczba partycji wszystkich danych wejściowych musi być taka sama.

PRZYKŁAD INTO

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

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId