상위 행 선택
| 항목 | 값 |
|---|---|
| 화면 이름 | Top rows |
| 식별자 | topRowV2 |
| 지원 실행 방식 | Batch, Faster |
| 범주 | 집계 (Aggregate) |
정렬된 각 파티션에서 상위 행을 선택합니다.
입력 인자
| 이름 | 지정 여부 | 자료형 | 의미와 조건 |
|---|---|---|---|
Dataset | 필수 | Table | 입력 데이터셋입니다. |
Partition by columns | 필수 | Set<Column<AnyType>> | 각 파티션을 결정할 열 집합입니다. |
Sort specification | 필수 | List<Tuple<Column<AnyType>, Enum<Ascending, Descending>>> | 파티션마다 적용할 정렬 명세입니다. 최소 하나가 필요합니다. |
Number of rows | 선택 | Literal<Integer> | 선택할 행 수이며 기본값은 1입니다. |
입출력 예시
예시 1: 기본 동작
인자 값:
Dataset: ri.foundry.main.dataset.aPartition by columns: {airline}Sort specification: [(airport,DESCENDING), (miles,ASCENDING)]Number of rows: null
입력:
| airline | airport | miles |
|---|---|---|
| foundry airways | JFK | 1002345 |
| foundry airways | LHR | 2221324 |
| new air | SFO | 21356673 |
| new air | JFK | 12323456 |
| foundry airways | LHR | 12542352 |
| new air | JFK | 12232355 |
출력:
| airline | airport | miles |
|---|---|---|
| foundry airways | LHR | 2221324 |
| new air | SFO | 21356673 |
예시 2: 기본 동작
인자 값:
Dataset: ri.foundry.main.dataset.aPartition by columns: {}Sort specification: [(airline,DESCENDING), (airport,DESCENDING), (miles,ASCENDING)]Number of rows: 2
입력:
| airline | airport | miles |
|---|---|---|
| foundry airways | JFK | 1002345 |
| foundry airways | LHR | 2221324 |
| new air | SFO | 21356673 |
| new air | JFK | 12323456 |
| foundry airways | LHR | 12542352 |
| new air | JFK | 12232355 |
출력:
| airline | airport | miles |
|---|---|---|
| new air | SFO | 21356673 |
| new air | JFK | 12232355 |
예시 3: 기본 동작
인자 값:
Dataset: ri.foundry.main.dataset.aPartition by columns: {}Sort specification: []Number of rows: 1
입력:
| airline | airport | miles |
|---|---|---|
| foundry airways | JFK | 1002345 |
| foundry airways | LHR | 2221324 |
| new air | SFO | 21356673 |
| new air | JFK | 12323456 |
| foundry airways | LHR | 12542352 |
| new air | JFK | 12232355 |
출력:
| airline | airport | miles |
|---|---|---|
| foundry airways | JFK | 1002345 |
예시 4: 기본 동작
인자 값:
Dataset: ri.foundry.main.dataset.aPartition by columns: {}Sort specification: [(value,ASCENDING)]Number of rows: 0
입력:
| value |
|---|
| 1 |
| 2 |
출력:
| value |
|---|