ksqlDB : Pseudo Column (자동 생성 컬럼)
- Kafka eco-system/ksqlDB
- 2022. 12. 17.
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
'Kafka eco-system > ksqlDB' 카테고리의 다른 글
카프카 스트림즈와 ksqlDB 정복 : ksqlDB 스트림 처리 기초 (10장) (0) | 2022.12.20 |
---|---|
Kafka Streams와 ksqlDB 정복 : ksqlDB 시작하기(8장) (1) | 2022.12.20 |
ksqlDB : ksqlDB의 간단한 구조 및 배포 모드 (0) | 2022.10.15 |
ksqlDB : Materialized View (0) | 2022.10.14 |
ksqlDB : 실시간 스트림 처리의 동작 방식 (0) | 2022.10.14 |