public T getParsedPayload()

in common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java [68:132]
65 lines of code
30 McCabe index (conditional complexity)

  public <T extends GeneratedMessageV3> T getParsedPayload() throws InvalidProtocolBufferException {
    switch (messageTypeValue) {
      case OPEN_STREAM_VALUE:
        return (T) PbOpenStream.parseFrom(payload);
      case STREAM_HANDLER_VALUE:
        return (T) PbStreamHandler.parseFrom(payload);
      case PUSH_DATA_HAND_SHAKE_VALUE:
        return (T) PbPushDataHandShake.parseFrom(payload);
      case REGION_START_VALUE:
        return (T) PbRegionStart.parseFrom(payload);
      case REGION_FINISH_VALUE:
        return (T) PbRegionFinish.parseFrom(payload);
      case BACKLOG_ANNOUNCEMENT_VALUE:
        return (T) PbBacklogAnnouncement.parseFrom(payload);
      case BUFFER_STREAM_END_VALUE:
        return (T) PbBufferStreamEnd.parseFrom(payload);
      case READ_ADD_CREDIT_VALUE:
        return (T) PbReadAddCredit.parseFrom(payload);
      case STREAM_CHUNK_SLICE_VALUE:
        return (T) PbStreamChunkSlice.parseFrom(payload);
      case CHUNK_FETCH_REQUEST_VALUE:
        return (T) PbChunkFetchRequest.parseFrom(payload);
      case TRANSPORTABLE_ERROR_VALUE:
        return (T) PbTransportableError.parseFrom(payload);
      case GET_SHUFFLE_ID_VALUE:
        return (T) PbGetShuffleId.parseFrom(payload);
      case GET_SHUFFLE_ID_RESPONSE_VALUE:
        return (T) PbGetShuffleIdResponse.parseFrom(payload);
      case REPORT_SHUFFLE_FETCH_FAILURE_VALUE:
        return (T) PbReportShuffleFetchFailure.parseFrom(payload);
      case REPORT_SHUFFLE_FETCH_FAILURE_RESPONSE_VALUE:
        return (T) PbReportShuffleFetchFailureResponse.parseFrom(payload);
      case REPORT_BARRIER_STAGE_ATTEMPT_FAILURE_VALUE:
        return (T) PbReportBarrierStageAttemptFailure.parseFrom(payload);
      case REPORT_BARRIER_STAGE_ATTEMPT_FAILURE_RESPONSE_VALUE:
        return (T) PbReportBarrierStageAttemptFailureResponse.parseFrom(payload);
      case SASL_REQUEST_VALUE:
        return (T) PbSaslRequest.parseFrom(payload);
      case AUTHENTICATION_INITIATION_REQUEST_VALUE:
        return (T) PbAuthenticationInitiationRequest.parseFrom(payload);
      case AUTHENTICATION_INITIATION_RESPONSE_VALUE:
        return (T) PbAuthenticationInitiationResponse.parseFrom(payload);
      case REGISTER_APPLICATION_REQUEST_VALUE:
        return (T) PbRegisterApplicationRequest.parseFrom(payload);
      case REGISTER_APPLICATION_RESPONSE_VALUE:
        return (T) PbRegisterApplicationResponse.parseFrom(payload);
      case APPLICATION_META_VALUE:
        return (T) PbApplicationMeta.parseFrom(payload);
      case APPLICATION_META_REQUEST_VALUE:
        return (T) PbApplicationMetaRequest.parseFrom(payload);
      case BATCH_OPEN_STREAM_VALUE:
        return (T) PbOpenStreamList.parseFrom(payload);
      case BATCH_OPEN_STREAM_RESPONSE_VALUE:
        return (T) PbOpenStreamListResponse.parseFrom(payload);
      case SEGMENT_START_VALUE:
        return (T) PbSegmentStart.parseFrom(payload);
      case NOTIFY_REQUIRED_SEGMENT_VALUE:
        return (T) PbNotifyRequiredSegment.parseFrom(payload);
      case PUSH_MERGED_DATA_SPLIT_PARTITION_INFO_VALUE:
        return (T) PbPushMergedDataSplitPartitionInfo.parseFrom(payload);
      default:
        logger.error("Unexpected type {}", type);
    }
    return null;
  }