- 주어진 group 조건에 따라 records를 집계하여 DataFrame을 만드는 연산자입니다.
- keyColName: key column으로 사용할 column 이름 (required)
- valColName: value column으로 사용할 column 이름 (required)
- groupby: 집계 방법. Enum(SUM, COUNT), (required)
| word |
count |
| I |
1 |
| am |
1 |
| so |
3 |
| happy |
4 |
| now |
2 |
| Are |
3 |
| you |
2 |
| happy |
6 |
| now |
8 |
| I |
1 |
| I |
3 |
| I |
5 |
| word |
count |
| you |
2 |
| now |
10 |
| Are |
3 |
| happy |
10 |
| I |
10 |
| so |
3 |
| am |
1 |
- keyColName('word'),valColName('count'),groupby(SUM)으로 parameter를 설정하였고 코드는 다음과 같다.
val groupbyInfo = GroupbyInfo.newBuilder()
.setKeyColName("word")
.setValColName("count")
.setGroupby(GroupbyInfo.GroupbyOp.SUM)
.build()
- word와 각 word에 대한 합계를 갖고있는 count column이 존재하는 결과 DataFrame을 확인할 수 있다.