ENHANCE: Change creating callback objects multiple times in pipe operation.

[brido4125]

관련 이슈

https://github.com/jam2in/arcus-works/issues/515

작업 내용

Piped 연산 시 op 인스턴스는 여러개 생성된다.
이와 동시에 callback 인스턴스도 여러개 생성된다.

하나의 콜백 인스턴스를 복수개의 op 인스턴스가 공유해서 사용하도록 변경한다.

[jhpark816]

리뷰 완료

[oliviarla]

@brido4125 현재 커밋이 3개입니다. rebase해주셔야 할 것 같습니다.

[jhpark816]

리뷰 완료

[jhpark816]

pipe 연산의 처리, 활용 방식을 정리할 때까지 본 PR 처리는 연기해야 할 것 같습니다.

[jhpark816]

리뷰 완료

최신 코드 기준으로 rebase 해 주세요.

[jhpark816]

key 설정하는 문장 아래로 옮깁시다.

[jhpark816]

인자 타입이 Integer, int가 혼용 사용되고 있는 데, int 타입으로 통일하면 될 것 같습니다.

참고로, 아래와 같이 구현할 수 있습니다.

      public void gotStatus(int opIdx, int elemIdx, OperationStatus status) {
        int index = (opIdx * CollectionPipedUpdate.MAX_PIPED_ITEM_COUNT) + elemIdx;
        if (status instanceof CollectionOperationStatus) {
          rv.addEachResult(index, (CollectionOperationStatus) status);
        } else {
          rv.addEachResult(index, new CollectionOperationStatus(status));
        }
      }

[jhpark816]

아니면, gotStatus()은 index 인자를 받고,
해당되는 index 값은 gotStatus() 호출하는 쪽에서 계산하여 넘기는 것이 나을 것 같습니다.

      public void gotStatus(int index, OperationStatus status) {
        if (status instanceof CollectionOperationStatus) {
          rv.addEachResult(index, (CollectionOperationStatus) status);
        } else {
          rv.addEachResult(index, new CollectionOperationStatus(status));
        }
      }

[jhpark816]

PartitionedMap 구현은 주어진 map 크기가 주어진 size 보다 작거나 같을 경우, 해당 map을 그대로 리턴하도록 최적화합시다.

[jhpark816]

인자 순서 검토 바람: list.get(i), i => i, list.get(i)

[brido4125]

pipe 연산의 처리, 활용 방식을 정리할 때까지 본 PR 처리는 연기해야 할 것 같습니다.

@jhpark816

PR 목록을 살펴보니 아직 pipe 관련된 변경사항이 merge 되진 않은 것 같습니다.
@oliviarla 님이 진행중인 작업이 마무리된 다음에 수정사항 반영해서 작업 하는게 좋을 것 같네요