Atlas Stream Processing 연속 데이터스트림을 처리 위해 집계 파이프라인 연산자를 지원합니다.
이러한 연산자 외에도 다음 표에는 Atlas Stream Processing 고유의 집계 파이프라인 표현식과 Atlas Stream Processing 에서 수정된 형태로 존재하는 표현식이 나열되어 있습니다.
집계 파이프라인 표현식 | 목적 |
|---|---|
Apache Kafka 헤더의 바이너리 데이터를 binData와 int, long, double 및 문자열 유형 간에 변환합니다. | |
Atlas Stream Processing 이 인스턴스를 평가할 때마다 스트림 처리 인스턴스 의 시스템 시간을 반환합니다. | |
문서 의 모든 스트리밍 메타데이터 포함된 객체 를 반환합니다. | |
UUID BSON types를 반환합니다. 이 표현식 인수를 받지 않습니다. |