groupingBy bucket 안에서 선택하는 downstream

원본 element List를 만든 뒤 후처리하지 않고 value를 직접 완성한다.

groupingBy(track)

counting

bucket 인원 수를 Long으로 만든다

scalar

mapping

Session을 topic으로 바꾼다

shape

filtering

key를 유지하며 조건을 적용한다

selection

flatMapping

nested tag를 같은 수준으로 펼친다

flatten

핵심: downstream 위치에 따라 Map value type과 빈 group 표현이 바뀐다.