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