항목 값
화면 이름 Time bounded drop out of order 식별자 timeBoundedDropOutOfOrderTransformV1지원 실행 방식 Streaming 범주 열, 행과 실행 제어 (Other)
같은 키의 이전 수신 행보다 정렬상 앞에 와야 하는 새 행을 제거합니다. 수신 순서대로 처리하면서 첫 정렬 열과 방향부터 비교하고 동점일 때만 다음 기준을 적용합니다. 모든 기준이 같으면 동등한 행입니다. 정렬 기준상 가장 뒤까지 진행한 행을 키별 상태로 보관하고, 새 행이 없는 이벤트 시간 구간이 만료 시간 이상이면 상태를 만료합니다. 만료 뒤 그 키의 첫 새 행은 제거하지 않고 새 기준 행으로 저장합니다.
이름 지정 여부 자료형 의미와 조건
Dataset필수 Table순서를 어긴 행을 제거할 데이터셋입니다. Key expiration time unit필수 Enum<Days, Hours, Milliseconds, Minutes, Seconds, Weeks>키별 정렬 기준 행을 보관할 시간 단위입니다. 다른 키를 처리하는 워터마크가 만료 기간을 넘으면 기존 키의 상태를 만료하며 이후 첫 행은 제거하지 않습니다. 새 레코드는 정렬상 최고 기준 행인지와 무관하게 해당 키의 만료 시점을 이 기간 뒤로 미룹니다. Key expiration time value필수 Literal<Long>키별 정렬 기준 행을 보관할 기간 값입니다. Ordering guarantee필수 List<Tuple<Column<ComparableType>, Enum<Ascending, Descending>>>스트림이 따라야 할 열과 정렬 방향입니다. 오름차순은 이전 기준과 같거나 커야 유지하고 내림차순은 반대입니다. 여러 기준은 앞선 기준이 동점일 때만 순서대로 적용합니다. Key by columns선택 Set<Column<Binary | Boolean | Byte | Double | Float | Integer | Long | Short | String | Timestamp>>입력을 분할할 키 열입니다. 같은 키는 수신 순서대로 처리하므로 지정한 정렬 순서와 다를 수 있습니다. 만료되지 않은 기준 상태보다 정렬상 앞에 와야 하는 행은 제외합니다.