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