스트림의 Java 그룹화

Question

Java 8 스트림을 사용하면 임의의 제약 조건으로 그룹화하면서 요소를 수집 할 수 있습니다. 예를 들어 :

Map<Type, List<MyThing>> grouped = stream 
    .collect(groupingBy(myThing -> myThing.type())); 

그러나이 스트림이 완전히 통해 읽을 수 있어야한다는 단점이있다, 그래서 grouped에 향후 작업의 게으른 평가의 기회가 없다.

Stream<Tuple<Type, Stream<MyThing>>>과 같은 항목을 얻기 위해 그룹화 작업을 수행 할 수있는 방법이 있습니까? 전체 데이터 세트를 평가하지 않고도 모든 언어로 지연 그룹화하는 것이 개념적으로 가능합니까?

Answer 1

게으른 그룹화 개념은 실제로 의미가 없습니다. 그룹화는 정의에 따라 각 키의 모든 요소를 ​​검색하는 오버 헤드를 피하기 위해 그룹을 미리 선택하는 것을 의미합니다. "게으른 그룹"과 같을 것이다 :

List<MyThing> get(Type key) { 
    source.stream() 
      .filter(myThing -> myThing.type().equals(key)) 
      .collect(toList()); 
} 

을 당신은 당신이 그것을 필요로하거나 그룹화 맵 캐싱의 메모리 오버 헤드를 피하기 위해 원하는 경우,이 완벽하게 잘 알고 때 반복을 연기하는 것을 선호합니다. 그러나 미리 반복하지 않고 선택 프로세스를 최적화 할 수는 없습니다.

Answer 2

나는이 다른 파티션에 사용되는 메모리의 임의의 큰 양을 생산할 수있는 게으른 스트림 Stream<Tuple<Type, Stream<MyThing>>>의 하나 개의 파티션 스트림 (Tuple<Type, Stream<MyThing>>)에서 읽기 때문에 이해한다고 생각하지 않습니다.

예. 자연의 순서로 양의 정수의 게으른 스트림을 고려하고 가장 작은 소수 요소로 그룹화하십시오. 그런 다음 파티션의 스트림에서 마지막으로 수신 된 요소를 읽으면 이전에받은 스트림에서 점점 더 많은 정수가 생성됩니다.

Answer 3

스트림은 중간 또는 터미널 스트림 작업을 호출 할 때 한 번만 작동해야합니다. 예를 들어, 같은 소스가 두 개 이상의 파이프 라인을 제공하는 "분기 된"스트림이나 동일한 스트림의 여러 탐색을 배제합니다.

https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html

그래서 내가 그것을 소비하는 새로운 스트림을 생성하지 않고 그것을 분할하는 방법이 없다고 생각 :

은의 문서에서 가져옵니다.

Answer 4

개념적으로 전체 데이터 집합을 평가하지 않고 언어를 그룹화하는 것이 가능합니까?

아니요, 전체 데이터 세트를 확인하거나 데이터의 악용 가능한 패턴을 보장하지 않으면 전체 데이터 세트를 올바르게 그룹화 할 수 없습니다. 예를 들어 처음 10,000 개의 정수를 느리게 짝수로 그룹화 할 수 있지만 임의로 10,000 개의 정수를 짝수로 그룹화 할 수는 없습니다.

비단식 방식으로 그룹화하는 것 ... 좋은 생각 인 것처럼 보이지는 않습니다. 개념적으로 스트림의 그룹화 함수는 여러 스트림을 분기하는 것처럼 여러 스트림을 반환해야하며 Java 8에서는이를 지원하지 않습니다.

네이티브 스트림 메서드를 사용하여 비단 말로 그룹화하려는 경우 정렬 된 메서드를 악용 할 수 있습니다. 그룹을 다르게 처리하지만 그룹 내의 모든 요소를 ​​동일하게 취급하는 분류기를 지정하면 group1, group2, group3 등으로 끝납니다.이것은 당신에게 게으른 평가를하지는 않지만 그룹핑입니다.