ksqlDB : Pseudo Column (자동 생성 컬럼)

    Pseudo Column

    Pseudo Column은 Table / Stream을 생성할 때 선언하지 않았지만 SELECT문으로 불러올 수 있는 Column을 의미한다. Pseudo Column은 레코드의 생성 시점의 메타정보를 담고 있다.  *를 이용해서 불러올 때는 불러지지 않지만, 명시적으로 이름을 표시해 줄 경우 SELECT 문에서 확인할 수 있다.

    Pseudo Column 의미
    HEADERS 카프카 레코드의 헤더에 있던 값이 채워진 열이다.
    ROWOFFSET Source Record의 Offset을 의미한다. (Source Node에서 받아왔을 때의 Offset 의미?)
    ROWPARTITION Source Record의 Partition을 의미한다. (Source Node에서 받아왔을 때의 Parition 의미?)
    ROWTIME Override 되지 않은 경우, 카프카 레코드의 Timestamp 값이다. 

    사용 방법

    SELECT ROWTIME, * FROM s1 EMIT CHANGES;
    • Projection으로 사용할 수 있다.
    • *와 함께 사용하고 싶을 때는 각 Pseudo Column + *로 선언해주면 됨.

    참고 

    https://docs.ksqldb.io/en/latest/reference/sql/data-definition/#pseudocolumns

     

    댓글

    Designed by JB FACTORY