발신자

✅ Azure Stream Analytics ✅ Fabric Eventstream

WITH 절에 연결된 입력 스트림 또는 단계 이름을 지정합니다. SELECT 문에는 항상 FROM 절이 필요합니다.

문법

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

반환할 열의 이름입니다. FROM 절의 두 입력 원본에 이름이 중복된 열이 있는 경우와 같이 모호한 참조를 방지하기 위해 column_name 한정합니다.

표현식

상수, 함수, 열 이름, 상수 및 연산자 또는 하위 쿼리로 연결된 함수의 조합입니다.

Column_alias

쿼리 결과 집합의 열 이름을 바꿀 대체 이름입니다. 예를 들어 Quantity, Quantity to Date 또는 Qty와 같은 별칭을 수량이라는 열에 지정할 수 있습니다. 별칭은 식의 결과에 대한 이름을 지정하는 데도 사용됩니다. WHERE, GROUP BY 또는 HAVING 절에는 column_alias 사용할 수 없습니다.

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