Pipeline Builder 표현식 참조
Pipeline Builder 표현식은 열의 값을 계산하거나 그룹과 윈도 안의 값을 처리합니다. 함수마다 입력 자료형, 반환 자료형과 null 처리 규칙이 다릅니다. Batch, Faster, Streaming은 지원 실행 방식의 이름입니다. 함수별로 명시된 방식 안에서 사용합니다.
Expression<T>는 T 값을 계산하는 표현식, Literal<T>는 T 리터럴을 뜻합니다. List는 목록, Set은 집합, Map은 키와 값의 대응, Struct는 필드를 가진 구조체입니다. T 같은 자료형 변수의 허용 범위는 개별 함수에 표시합니다. 집계와 윈도 표현식의 행 범위 및 정렬은 해당 파이프라인 구성과 함께 적용합니다.
예시에는 인자 값과 입력/출력이 함께 있습니다. null 처리와 ANSI 모드, 인덱스 경계의 동작도 함수별 예시에 따릅니다. 난수와 LLM의 예시값을 반복 실행의 고정 결과로 사용하지 않습니다.
구조체
구조체의 필드를 생성하거나 읽고 변경하는 표현식입니다. 중첩 필드는 경로 요소로 지정합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 구조체 필드 추가 또는 갱신 | addOrUpdateStructFieldV1 | Batch, Faster, Streaming |
| 구조체 열 생성 | createStructV2 | Batch, Faster, Streaming |
| 구조체 필드 추출 | getStructFieldV2 | Batch, Faster, Streaming |
기타
조건 분기, Cipher 암호화와 복호화 및 해시, 위임 미디어 식별자와 분류 문자열 해석을 다룹니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 조건별 분기 선택 | caseV2 | Batch, Faster, Streaming |
| Cipher 복호화 | cipherDecryptV1 | Batch, Faster, Streaming |
| Cipher 암호화 | cipherEncryptV1 | Batch, Faster, Streaming |
| Cipher 해시 | cipherHashV1 | Batch, Faster, Streaming |
| 위임 미디어의 Gotham GID 생성 | constructDelegatedMediaGidV1 | Batch, Streaming |
| 분류 문자열 해석 | cbacStringToGroupNamesV3 | Batch, Streaming |
날짜와 시간
날짜와 타임스탬프의 해석, 형식, 시간대와 기간 계산을 다룹니다. 날짜/시간 형식의 기본값과 시간대 조건을 유지해야 합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 날짜에 기간 더하기 | dateAddV2 | Batch, Faster, Streaming |
| 타임스탬프 시간대 변경 | changeTimestampTimeZoneV1 | Batch, Faster |
| 시간 단위 변환 | convertTimeV1 | Batch, Faster, Streaming |
| 기존 OffsetDateTime 변환 | convertLegacyOffsetDateTimeV1 | Batch |
| UTC에서 지정 시간대로 변환 | timestampFromUtcV1 | Batch, Faster, Streaming |
| 지정 시간대에서 UTC로 변환 | timestampToUtcV1 | Batch, Faster, Streaming |
| 현재 날짜 | currentDateV1 | Batch, Faster, Streaming |
| 현재 타임스탬프 | currentTimestampV2 | Batch, Faster, Streaming |
| 날짜 수열 | dateSequenceV1 | Batch, Faster |
| 날짜 구성 요소 추출 | datePartV1 | Batch, Faster, Streaming |
| 기존 OffsetDateTime의 오프셋 추출 | extractOffsetFromLegacyOffsetDateTimeV1 | Batch |
| 타임스탬프 구성 요소 추출 | timestampPartV1 | Batch, Faster, Streaming |
| 기간의 마지막 날짜 | lastDayV1 | Batch, Faster |
| 다음 요일의 날짜 | nextDayV1 | Batch |
| 기간 문자열 해석 | parseDurationV1 | Batch |
| 날짜에서 기간 빼기 | dateSubV2 | Batch, Faster, Streaming |
| 타임스탬프에 값 더하기 | timestampAddV1 | Batch, Faster, Streaming |
| 타임스탬프 차이 | timestampDiffV1 | Batch, Faster, Streaming |
| 타임스탬프 수열 | timestampSequenceV1 | Batch, Faster |
| 타임스탬프에서 값 빼기 | timestampSubtractV1 | Batch, Faster, Streaming |
| 날짜 절삭 | dateTruncateV1 | Batch, Faster |
| 타임스탬프 절삭 | timestampTruncateV1 | Batch, Faster |
네트워크 식별자
IP 주소와 관련 식별자를 해석하거나 유효성을 확인하는 표현식입니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| IPv6 표준 표기 | ipV6ToCanonicalIpV6V1 | Batch |
| IPv4 유효성 | isValidIpV4V1 | Batch |
| IPv6 유효성 | isValidIpV6V1 | Batch |
논리
값 비교와 조건식을 다룹니다. null 전파와 ANSI 모드가 결과에 영향을 주는 함수는 해당 예시를 함께 확인합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 조건 AND | andV1 | Batch, Faster, Streaming |
| 문자열의 끝 일치 여부 | endsWithV1 | Batch, Faster, Streaming |
| 값의 동등성 | equalsV1 | Batch, Faster, Streaming |
| 보다 큼 | greaterThanV2 | Batch, Faster, Streaming |
| 크거나 같음 | greaterThanOrEqualsV2 | Batch, Faster, Streaming |
| 빈 구조체 여부 | isEmptyStructV1 | Batch, Streaming |
| 목록의 값 포함 여부 | isInV1 | Batch, Faster, Streaming |
| NaN 여부 | isNaNV1 | Batch, Faster, Streaming |
| null 아님 여부 | isNotNullV1 | Batch, Faster, Streaming |
| null 여부 | isNullV1 | Batch, Faster, Streaming |
| 위임 미디어 GID 유효성 | isValidDelegatedMediaGidV1 | Batch, Faster, Streaming |
| 미디어 참조 유효성 | isValidMediaReferenceV2 | Batch, Faster, Streaming |
| MIME 유형 유효성 | isValidMimeTypeV1 | Batch, Faster, Streaming |
| Foundry RID 유효성 | isValidRidV1 | Batch, Faster, Streaming |
| UUID 유효성 | isValidUuidV1 | Batch, Faster, Streaming |
| 입력 열 중 최솟값 | leastV1 | Batch, Faster, Streaming |
| 보다 작음 | lessThanV2 | Batch, Faster, Streaming |
| 작거나 같음 | lessThanOrEqualsV2 | Batch, Faster, Streaming |
| Boolean 부정 | notV1 | Batch, Faster, Streaming |
| 어느 조건도 충족하지 않음 | notAnyV1 | Batch, Streaming |
| 조건 OR | orV1 | Batch, Faster, Streaming |
| 문자열의 시작 일치 여부 | startsWithV1 | Batch, Faster, Streaming |
| 문자열 포함 여부 | stringContainsV1 | Batch, Faster, Streaming |
데이터 정리
문자열 정리, null 대체, JSON 스키마 해석과 구조체 필드 이름 변경을 다룹니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 문자열 정리 | cleanStringV1 | Batch, Faster, Streaming |
| null 값 생성 | createNullValueV1 | Batch, Faster, Streaming |
| 첫 번째 null 아닌 값 | firstNonNullV1 | Batch, Faster, Streaming |
| 맵에 따른 값 변환 | mapValuesV2 | Batch, Faster, Streaming |
| JSON 문자열 해석 | parseJsonAsSchemaV3 | Batch, Faster, Streaming |
| 구조체 필드 이름 변경 | renameStructFieldV1 | Batch, Faster, Streaming |
| 양끝 공백 제거 | trimV1 | Batch, Faster, Streaming |
| 유니코드 정규화 | unicodeNormalizeV1 | Batch, Faster, Streaming |
맵
키와 값의 대응을 생성하고 변경하는 표현식입니다. null 키와 중복 키의 처리 규칙은 각 함수에 따릅니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 맵 항목 추가 또는 갱신 | addOrUpdateMapEntryV1 | Batch, Streaming |
| 맵을 행으로 펼치기 | explodeMapV1 | Batch, Streaming |
| 맵 키 추출 | extractMapKeysV1 | Batch, Faster, Streaming |
| 맵 값 추출 | extractMapValuesV1 | Batch, Faster, Streaming |
| 키로 맵 항목 제거 | removeMapEntryByKeyV1 | Batch, Streaming |
| 맵 키 변환 | transformMapKeysV1 | Batch, Streaming |
| 맵 값 변환 | transformMapValuesV1 | Batch |
| 맵에서 값 찾기 | valueFromMapV1 | Batch, Faster, Streaming |
문자열
문자열의 분리, 결합, 서식과 문자를 처리합니다. 위치 인덱스, 대소문자와 공백의 정의가 함수마다 다를 수 있습니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 문자별 치환 | translateStringV1 | Batch, Faster, Streaming |
| 문자열 조각 나누기 | chunkStringV1 | Batch, Streaming |
| 문자열 이어 붙이기 | concatStringsV1 | Batch, Faster, Streaming |
| 16진수에서 문자열로 변환 | UnhexToStringV1 | Batch, Faster, Streaming |
| 시계열 참조 값 생성 | createQualifiedTimeSeriesIdV1 | Batch, Streaming |
| printf 방식 문자열 서식 | formatStringV1 | Batch, Streaming |
| SHA-256 해시 | sha256V1 | Batch, Faster, Streaming |
| 문자열 왼쪽 부분 | leftStringV1 | Batch, Faster, Streaming |
| 문자열 왼쪽 채우기 | leftPadV1 | Batch, Faster, Streaming |
| 소문자 변환 | lowercaseV1 | Batch, Faster, Streaming |
| 빈 문자열을 null로 변환 | nullifyEmptyStringV1 | Batch, Faster, Streaming |
| 전화번호 해석과 정규화 | parsePhoneNumberV2 | Batch, Faster, Streaming |
| 시맨틱 버전 해석 | parseSemanticVersionV1 | Batch, Streaming |
| 문자열 오른쪽 부분 | rightStringV1 | Batch, Faster, Streaming |
| 문자열 오른쪽 채우기 | rightPadV1 | Batch, Faster, Streaming |
| 문장 첫 글자 대문자화 | sentenceCaseV1 | Batch, Faster, Streaming |
| Soundex 인코딩 | soundexV1 | Batch, Faster |
| 정규식으로 문자열 분리 | splitStringV2 | Batch, Faster, Streaming |
| 구분자 뒤 문자열 | stringAfterDelimiterV1 | Batch, Faster, Streaming |
| 구분자 앞 문자열 | stringBeforeDelimiterV1 | Batch, Faster, Streaming |
| 텍스트 분할 | textSegmentationV1 | Batch, Faster, Streaming |
| 텍스트 임베딩 | textToEmbeddingsV2 | Batch |
| 단어 첫 글자 대문자화 | titleCaseV1 | Batch, Faster, Streaming |
| 비결정적 UUID 생성 | uuidV1 | Batch, Faster, Streaming |
| 대문자 변환 | uppercaseV1 | Batch, Faster, Streaming |
| URL 인코딩 | urlEncodeV1 | Batch, Faster, Streaming |
| LLM 호출 | useLlmV3 | Batch |
| 결정적 UUID v5 | uuidV5V1 | Batch, Faster, Streaming |
미디어
이미지, 문서, 오디오와 영상의 참조, 내용 추출과 모델 처리를 다룹니다. 입력 미디어 형식과 오류 출력 모드를 확인합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 미디어 스키마 변환 | castMediaSchemaV1 | 미지정 |
| 오디오 메타데이터 추출 | getAudioMetadataV1 | Batch |
| 스프레드시트 내용을 JSON으로 추출 | spreadsheetJsonExtractionV1 | Batch |
| 문서 메타데이터 추출 | getDocumentMetadataV1 | Batch, Faster |
| 이메일 본문 추출 | extractEmailBodyV1 | Batch |
| 이미지 메타데이터 추출 | getImageryMetadataV1 | Batch, Streaming |
| 이미지 레이아웃 인식 추출 | imageLayoutAwareContentExtractionV2 | Batch, Faster |
| PDF 레이아웃 인식 추출 | pdfLayoutAwareContentExtractionV2 | Batch, Faster |
| PDF 목차 추출 | pdfTableOfContentsV1 | Batch, Faster |
| OCR로 이미지 텍스트 추출 | imageOcrV2 | Batch, Faster |
| PDF 텍스트 추출 | pdfTextExtractionV2 | Batch, Faster |
| OCR로 PDF 텍스트 추출 | pdfOcrV2 | Batch, Faster |
| 미디어 MIME 유형 | getMimeTypeV1 | 미지정 |
| PDF 페이지 크기 | getPdfPageDimensionsV1 | Batch, Faster |
| 영상 장면 전환 시각 | getTimestampsForSceneFramesV1 | Batch |
| 미디어 스키마 일치 여부 | hasMediaSchemaV1 | Batch |
| 이미지 임베딩 | imageToEmbeddingsV1 | Batch |
| CPU로 오디오를 JSON 전사 | cpuJsonAudioTranscriptionV1 | Batch |
| GPU로 오디오를 JSON 전사 | gpuJsonAudioTranscriptionV1 | Batch |
| 오디오를 텍스트로 전사 | audioTranscriptionV1 | Batch, Faster |
바이너리
바이너리의 인코딩, 디코딩과 바이트 처리를 다룹니다. 문자열 변환에는 문자 집합과 결과 자료형이 함께 적용됩니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| Base64를 문자열로 디코딩 | base64DecodeToStringV1 | Batch, Faster, Streaming |
| Base64 디코딩 | base64DecodeV1 | Batch, Faster, Streaming |
| Base64 인코딩 | base64EncodeV1 | Batch, Faster, Streaming |
| 비트 왼쪽 이동 | bitShiftLeftV1 | Batch, Streaming |
| 비트 오른쪽 이동 | bitShiftRightV1 | Batch, Streaming |
| 진법 변환 | convertBaseV1 | Batch, Streaming |
| 문자 집합으로 디코딩 | decodeV1 | Batch, Faster, Streaming |
| 바이트 건너뛰기 | skipBytesV1 | Batch, Faster, Streaming |
배열
배열의 원소, 순서와 중복을 다루는 표현식입니다. 위치 기반 연산은 함수별 인덱스 기준과 음수 처리 조건을 확인합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 모든 배열 원소의 조건 충족 | allArrayElementsSatisfyV1 | Batch, Streaming |
| 배열 원소 중 하나 이상의 조건 충족 | anyArrayElementSatisfyV1 | Batch, Streaming |
| 배열에 원소 추가 | arrayAddV1 | Batch, Faster, Streaming |
| 배열의 데카르트 곱 | arraysCartesianProductV1 | Batch, Streaming |
| 배열 이어 붙이기 | arrayConcatV1 | Batch, Faster, Streaming |
| 배열의 값 포함 여부 | arrayContainsV1 | Batch, Faster, Streaming |
| 배열의 null 포함 여부 | arrayContainsNullV1 | Batch, Faster, Streaming |
| 배열 차집합 | arrayDifferenceV1 | Batch, Faster, Streaming |
| 배열 중복 제거 | arrayDistinctV1 | Batch, Faster, Streaming |
| 배열 위치의 원소 | arrayElementV1 | Batch, Faster, Streaming |
| 배열 원소의 유일성 | isArrayUniqueV1 | Batch, Faster, Streaming |
| 중첩 배열 펼치기 | arrayFlattenV2 | Batch, Faster, Streaming |
| 배열 교집합 | arrayIntersectV1 | Batch, Faster, Streaming |
| 배열 최댓값 | arrayMaxV1 | Batch, Faster, Streaming |
| 배열 최솟값 | arrayMinV1 | Batch, Faster, Streaming |
| 배열에서 값의 위치 찾기 | arrayPositionV1 | Batch, Faster, Streaming |
| 배열에서 값 제거 | arrayRemoveV1 | Batch, Faster, Streaming |
| 배열 반복 | arrayRepeatV1 | Batch, Faster, Streaming |
| 배열 순서 뒤집기 | arrayReverseV1 | Batch, Faster, Streaming |
| 배열 정렬 | arraySortV1 | Batch, Faster, Streaming |
| 구조체 키로 배열 정렬 | arraySortByKeyV2 | Batch, Streaming |
| 배열 합집합 | arrayUnionV1 | Batch, Faster, Streaming |
| 배열의 공통 원소 여부 | arraysHaveIntersectionV1 | Batch, Faster, Streaming |
| 배열을 구조체로 묶기 | arraysZipV1 | Batch, Faster, Streaming |
| 빈 배열 생성 | createEmptyArrayV1 | Batch, Faster, Streaming |
| 열로 배열 생성 | createArrayV1 | Batch, Faster, Streaming |
| 배열로 맵 생성 | mapFromArraysV1 | Batch, Faster, Streaming |
| 배열을 행으로 펼치기 | explodeArrayV1 | Batch, Faster, Streaming |
| 배열 원소와 위치를 행으로 펼치기 | explodeArrayWithPositionV2 | Batch, Streaming |
| 배열 원소 필터링 | filterArrayElementV1 | Batch, Streaming |
| 배열 문자열 결합 | arrayJoinV1 | Batch, Faster, Streaming |
| 문자열 또는 배열 길이 | lengthV1 | Batch, Faster, Streaming |
| 배열 분할 | arrayPartitionV1 | Batch, Streaming |
| 배열 원소 축약 | reduceArrayElementsV1 | Batch, Streaming |
| 숫자 수열 | sequenceV2 | Batch, Faster, Streaming |
| 배열 구간 추출 | arraySliceV1 | Batch, Faster, Streaming |
| 배열 원소 합계 | arraySumV1 | Batch, Faster, Streaming |
| 배열 원소 변환 | transformArrayElementV1 | Batch, Streaming |
숫자
숫자의 연산, 집계, 난수와 수학 함수를 다룹니다. 같은 이름의 일반 수학 연산이라도 반환 자료형과 null 처리 조건을 함께 적용합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 절댓값 | absV1 | Batch, Faster, Streaming |
| 숫자 더하기 | addV2 | Batch, Faster, Streaming |
| 역코사인 | arccosV1 | Batch, Faster, Streaming |
| 역사인 | arcsinV1 | Batch, Faster, Streaming |
| 역탄젠트 | arctanV1 | Batch, Faster, Streaming |
| 좌표의 역탄젠트 | arctan2V1 | Batch, Faster, Streaming |
| 올림값 | ceilV1 | Batch, Faster, Streaming |
| 거리 단위 변환 | convertDistanceV1 | Batch, Faster, Streaming |
| 무게 단위 변환 | convertWeightV1 | Batch, Faster, Streaming |
| 16진수에서 바이너리로 변환 | UnhexV1 | Batch, Faster |
| 16진수 표현 | HexV1 | Batch, Faster, Streaming |
| 8진수 표현 | octalV1 | Batch, Faster, Streaming |
| 코사인 | cosineV1 | Batch, Faster, Streaming |
| 숫자 나누기 | divideV1 | Batch, Faster, Streaming |
| 지수 함수 | exponentialV1 | Batch, Faster, Streaming |
| 내림값 | floorV1 | Batch, Faster, Streaming |
| 입력 열 중 최댓값 | greatestV1 | Batch, Faster, Streaming |
| 자연로그 | logV1 | Batch, Faster, Streaming |
| 지정한 밑의 로그 | logNV1 | Batch, Faster, Streaming |
| 열 최댓값 | maxV1 | Batch, Faster, Streaming |
| 평균 | meanV1 | Batch, Faster, Streaming |
| 중앙값 | medianV1 | Batch, Faster |
| 열 최솟값 | minV1 | Batch, Faster, Streaming |
| 나머지 | moduloV1 | Batch, Faster, Streaming |
| 숫자 곱하기 | multiplyV2 | Batch, Faster, Streaming |
| 자연수 난수 | naturalRandomV1 | Batch, Faster, Streaming |
| 숫자 부호 반전 | negateV1 | Batch, Faster, Streaming |
| 정규분포 난수 | normalRandomV1 | Batch, Faster, Streaming |
| 양의 나머지 | positiveModuloV1 | Batch, Faster |
| 거듭제곱 | powerOfV1 | Batch, Faster, Streaming |
| 곱 집계 | productV1 | Batch |
| 숫자 반올림 | roundV1 | Batch, Faster, Streaming |
| 시컨트 | secantV1 | Batch, Faster, Streaming |
| 사인 | sineV1 | Batch, Faster, Streaming |
| 제곱근 | sqrtV1 | Batch, Faster, Streaming |
| 표준편차 | standardDeviationV1 | Batch, Faster |
| 부분 문자열 | substringV1 | Batch, Faster, Streaming |
| 여러 표현식 빼기 | subtractManyV1 | Batch, Faster, Streaming |
| 숫자 빼기 | subtractV1 | Batch, Faster, Streaming |
| 합계 | sumV1 | Batch, Faster, Streaming |
| 탄젠트 | tangentV1 | Batch, Faster, Streaming |
| 균등분포 난수 | uniformRandomV1 | Batch, Faster, Streaming |
유사도와 거리
문자열과 임베딩의 유사도 또는 거리를 비교합니다. 점수가 커질수록 유사한지, 반대로 차이가 큰지를 각 지표의 정의에서 확인합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 문자열 편집 거리 | levenshteinDistanceV2 | Batch, Faster, Streaming |
| ROUGE 점수 | rougeScoreV1 | Batch |
| 임베딩 유사도 | similarityScoreV1 | Batch |
| 토큰 집합 유사도 비율 | tokenSetRatioV1 | Batch, Streaming |
자료형 변환
기본 자료형, 논리 자료형과 문자열 표현을 변환합니다. 변환 실패의 null 또는 오류 출력 계약은 함수마다 다릅니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 자료형 변환 | castV2 | Batch, Faster, Streaming |
| 문자열을 날짜로 변환 | stringToDateV3 | Batch, Faster, Streaming |
| 문자열을 타임스탬프로 변환 | stringToTimestampV3 | Batch, Faster, Streaming |
| Epoch 밀리초를 날짜로 변환 | epochMillisToDateV1 | Batch, Faster, Streaming |
| Epoch 밀리초를 타임스탬프로 변환 | epochMillisToTimestampV1 | Batch, Faster, Streaming |
| Epoch 초를 날짜로 변환 | epochSecondsToDateV1 | Batch, Faster, Streaming |
| Epoch 초를 타임스탬프로 변환 | epochSecondsToTimestampV1 | Batch, Faster, Streaming |
| 날짜를 문자열로 서식 지정 | dateToStringV2 | Batch, Faster, Streaming |
| 숫자 서식 지정 | formatNumberV1 | Batch, Faster, Streaming |
| 타임스탬프를 문자열로 서식 지정 | timestampToStringV2 | Batch, Faster, Streaming |
| 논리 자료형 변환 | logicalTypeCastV1 | Batch, Faster, Streaming |
| 타임스탬프를 Epoch 밀리초로 변환 | timestampToEpochMillisV1 | Batch, Faster, Streaming |
| 타임스탬프를 Epoch 초로 변환 | timestampToEpochSecondsV1 | Batch, Faster, Streaming |
| URL 디코딩 | urlDecodeV1 | Batch, Faster, Streaming |
정규식
정규식의 부분 일치, 전체 일치, 추출과 치환을 다룹니다. 일치가 없는 경우와 null 패턴의 결과를 구분합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 정규식 일치 항목 전체 추출 | regexExtractAllV1 | Batch, Faster, Streaming |
| 정규식 그룹 추출 | regexExtractV1 | Batch, Faster, Streaming |
| 정규식 부분 일치 | regexFindV1 | Batch, Faster, Streaming |
| 정규식 일치 위치 | regexIndexV2 | Batch, Faster, Streaming |
| 정규식 전체 일치 | regexMatchV2 | Batch, Faster, Streaming |
| 정규식 치환 | regexReplaceV1 | Batch, Faster, Streaming |
지리공간
좌표, 지리 인덱스와 도형을 다룹니다. WGS84 변환, 좌표계의 단위, 날짜 변경선과 도형 유효성 조건을 함수별로 확인합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| 도형 면적 | areaV1 | Batch, Streaming |
| H3 인덱스의 버퍼 | h3BufferV1 | Batch, Faster, Streaming |
| 목적지 좌표 계산 | inverseHaversineV1 | Batch, Faster, Streaming |
| Haversine 거리 계산 | haversineV1 | Batch, Faster, Streaming |
| H3 인덱스 집합 압축 | compactH3SetV1 | Batch, Faster, Streaming |
| 각도 단위 변환 | convertAngleV1 | Batch, Faster, Streaming |
| DMS 문자열을 GeoPoint로 변환 | dmsToGeoPointV1 | Batch, Faster, Streaming |
| 온톨로지 GeoPoint를 구조체로 변환 | ontologyGeopointToGeopointV1 | Batch, Faster, Streaming |
| 지구 중심 좌표를 WGS84 좌표로 변환 | GeocentricToGeodesicV1 | Batch, Streaming |
| GeoPoint를 DMS 문자열로 변환 | geoPointToDmsV1 | Batch, Faster, Streaming |
| GeoPoint를 Geohash로 변환 | geoPointToGeohashV1 | Batch, Faster, Streaming |
| GeoPoint를 도형으로 변환 | geoPointToGeometryV1 | Batch, Faster, Streaming |
| GeoPoint를 MGRS로 변환 | geoPointToMgrsV1 | Batch, Faster, Streaming |
| H3 인덱스를 GeoPoint로 변환 | h3ToGeoPointV1 | Batch, Faster, Streaming |
| 선 문자열을 다각형으로 변환 | linestringToPolygonV1 | Batch, Faster, Streaming |
| MGRS를 GeoPoint로 변환 | mgrsToGeoPointV1 | Batch, Faster, Streaming |
| 온톨로지 GeoPoint 문자열 생성 | createOntologyGeopointV1 | Batch, Faster, Streaming |
| 타원 도형 생성 | createGeoEllipseGeometryV1 | Batch, Faster, Streaming |
| 측지선 생성 | createGeodesicLineStringV1 | Batch, Streaming |
| 위도와 경도로 GeoPoint 생성 | constructGeoPointV1 | Batch, Faster, Streaming |
| 좌표계에서 GeoPoint 생성 | createGeoPointFromCoordinateSystemV1 | Batch, Faster, Streaming |
| 지리 시계열 참조 생성 | constructGeotemporalSeriesReferenceV1 | Batch, Faster, Streaming |
| 선 문자열 도형 생성 | createGeoLineStringV1 | Batch, Streaming |
| 거리와 방위각의 부채꼴 도형 | createGeoRangeFanGeometryV1 | Batch, Streaming |
| 정렬된 GeoPoint 행으로 도형 생성 | createGeometryFromOrderedGeoPointRowsV1 | Batch |
| Geobuf를 GeoJSON으로 디코딩 | geobufToGeometryExpressionV1 | Batch, Streaming |
| GeoJSON을 Geobuf로 인코딩 | geometryToGeobufExpressionV1 | Batch, Faster, Streaming |
| 도형 유형으로 필터링 | geometryFilterV1 | Batch, Faster, Streaming |
| 도형 교차 여부 | geometryIntersectsV1 | Batch, Faster, Streaming |
| 도형의 3차원 아핀 변환 | geometry3dAffineTransformationV1 | Batch, Faster, Streaming |
| 도형 배열 합집합 | geometryArrayUnionV1 | Batch, Faster, Streaming |
| 도형 배열의 선 병합 | geometryArrayLineDissolveV1 | Batch, Faster, Streaming |
| 도형 버퍼 | geometryBufferV1 | Batch, Streaming |
| 도형의 중심점 | geometryCentroidV1 | Batch, Streaming |
| 도형 포함 여부 | geometryContainsV1 | Batch, Faster, Streaming |
| 도형 차집합 | geometryDifferenceV1 | Batch, Faster, Streaming |
| 도형을 단순 도형 배열로 펼치기 | geometryExplodeToArrayV1 | Batch, Faster, Streaming |
| 도형 교집합 | geometryIntersectionV1 | Batch, Faster, Streaming |
| 도형의 선 길이 | geometryLengthV1 | Batch, Streaming |
| 도형의 2차원 회전 | geometryRotate2dV1 | Streaming |
| 도형 z 좌표 설정 | geometrySetZCoordinateV1 | Batch, Faster, Streaming |
| 도형 사이 최단 거리 | geometryShortestDistanceV1 | Batch, Streaming |
| 도형 표준화 | geometryStandardizeV1 | Batch, Faster, Streaming |
| 도형 대칭 차집합 | geometrySymmetricDifferenceV1 | Batch, Faster, Streaming |
| 도형 평행이동 | geometryTranslateV1 | Batch, Faster, Streaming |
| 두 도형의 합집합 | geometryUnionV1 | Batch, Faster, Streaming |
| 시작점에서 끝점의 방위각 | getBearingV1 | Batch, Faster, Streaming |
| 도형 경계 사각형 | geometryEnvelopeV1 | Batch, Streaming |
| GeoPoint의 H3 인덱스 | h3IndexExpressionV1 | Batch, Faster, Streaming |
| 도형을 덮는 H3 인덱스 | polygonToH3V1 | Batch, Faster, Streaming |
| 위도와 경도 경계 구조체 | latLonBoundingBoxV1 | Batch, Faster, Streaming |
| H3 이웃 인덱스 | h3NeighborsV1 | Batch, Faster, Streaming |
| 도형의 볼록 껍질 | geometryConvexHullV1 | Batch, Faster, Streaming |
| 경계 영역의 XZ 곡선 인덱스 | xzCurveEncodeV1 | Batch, Streaming |
| 그룹 도형의 경계 사각형 | groupedGeometryEnvelopeV1 | Batch, Faster |
| 그룹 도형 합집합 | groupedGeometryUnionV1 | Batch |
| 그룹의 위도와 경도 경계 | groupedLatLonBoundingBoxV1 | Batch |
| H3 자식 셀 | h3CellToChildrenV1 | Batch, Faster, Streaming |
| H3 부모 셀 | h3CellToParentV1 | Batch, Faster, Streaming |
| H3 인덱스를 도형으로 변환 | h3ToGeometryV1 | Batch, Faster, Streaming |
| 선 위의 GeoPoint 보간 | interpolateGeoPointAlongLinestringV1 | Batch, Streaming |
| Geohash 유효성 | isValidGeohashV1 | Batch, Faster, Streaming |
| GeoJSON 유효성 | isValidGeoJsonV1 | Batch, Faster, Streaming |
| H3 인덱스 유효성 | isValidH3IndexV1 | Batch, Faster, Streaming |
| MGRS 유효성 | isValidMgrsV1 | Batch, Faster, Streaming |
| 온톨로지 GeoPoint 유효성 | isValidOntologyGeopointV1 | Batch, Faster, Streaming |
| 다각형의 n번째 고리 | getNthChainFromPolygonV1 | Batch, Faster, Streaming |
| 선 문자열의 n번째 점 | linestringPointNV1 | Batch, Faster, Streaming |
| 다른 좌표계의 GeoJSON 해석 | parseGeoJsonAsGeometryV1 | Batch, Faster, Streaming |
| KML 문자열을 도형으로 해석 | parseKmlAsGeometryV1 | Batch, Streaming |
| KML 문자열을 도형 목록으로 해석 | parseKmlAsGeometryListV1 | Batch, Streaming |
| WKB를 도형으로 해석 | parseWellKnownBinaryAsGeometryV1 | Batch, Faster, Streaming |
| WKT를 도형으로 해석 | parseWellKnownTextAsGeometryV1 | Batch, Faster, Streaming |
| 도형 둘레 | perimeterV1 | Batch, Streaming |
| 후속 처리를 위한 도형 준비 | normalizeGeometryV4 | Batch, Streaming |
| 도형 단순화 | simplifyGeometryV1 | Batch, Faster, Streaming |
| H3 인덱스 집합 압축 해제 | uncompactH3SetV1 | Batch, Faster, Streaming |
집계
여러 행의 값을 집계하는 표현식입니다. 그룹의 범위와 null 처리, 순위 또는 선택 기준을 각 함수의 계약에 맞춰 구성합니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| Boolean AND 집계 | allOfV2 | Batch, Faster |
| Boolean OR 집계 | anyOfV2 | Batch, Faster |
| 근사 중앙값 | approxMedianV1 | Batch |
| 근사 분위수 | approximatePercentileV1 | Batch |
| 그룹 값을 배열로 모으기 | collectArrayV1 | Batch, Faster, Streaming |
| 그룹의 고유 값을 배열로 모으기 | collectDistinctArrayV1 | Batch, Faster, Streaming |
| 모집단 공분산 | covarianceV1 | Batch, Streaming |
| 간격 없는 순위 | denseRankV1 | Batch, Faster |
| 고유 값 개수 | distinctCountV1 | Batch, Faster, Streaming |
| 그룹의 첫 값 | firstV1 | Batch, Faster, Streaming |
| 이전 행 값 | lagV1 | Batch, Faster |
| 그룹의 마지막 값 | lastV1 | Batch, Faster, Streaming |
| 이후 행 값 | leadV1 | Batch, Faster |
| 선형 회귀 기울기 | linearRegressionGradientV2 | Batch |
| 조건에 맞는 최대 행 | maxByV1 | Streaming |
| 조건에 맞는 최소 행 | minByV1 | Streaming |
| 최빈값 | modeV1 | Batch, Faster |
| 백분위 순위 | percentRankV1 | Batch, Faster |
| 피벗 집계 | pivotExpressionV1 | Streaming |
| 순위 | rankV1 | Batch, Faster |
| 행 개수 | rowCountV1 | Batch, Faster, Streaming |
| 행 번호 | rowNumberV1 | Batch, Faster, Streaming |
| 표본 공분산 | sampleCovarianceV1 | Batch, Streaming |
| 표본 분산 | sampleVarianceV1 | Batch, Faster, Streaming |
| 모집단 분산 | varianceV1 | Batch, Faster, Streaming |
파일
JSON과 XML의 표현 및 스키마 해석, gzip 압축 데이터 처리를 다룹니다.
| 표현식 | 식별자 | 지원 실행 방식 |
|---|---|---|
| JSON 문자열로 변환 | jsonStringV2 | Batch, Faster, Streaming |
| Gzip 압축 해제 | gzipDecompressV1 | Batch, Faster, Streaming |
| XML 문자열을 스키마로 해석 | parseXmlAsSchemaV2 | Batch, Streaming |