public EventBridgeMappingResult map()

in src/main/java/software/amazon/event/kafkaconnector/mapping/DefaultEventBridgeMapper.java [37:49]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  public EventBridgeMappingResult map(List<SinkRecord> records) {
    var partition =
        records.stream()
            .map(this::createPutEventsEntry)
            .collect(partitioningBy(EventBridgeResult::isSuccess));

    var successfulMappedRecords =
        partition.get(true).stream().map(EventBridgeResult::success).collect(toList());
    var failedMappedRecords =
        partition.get(false).stream().map(EventBridgeResult::failure).collect(toList());

    return new EventBridgeMappingResult(successfulMappedRecords, failedMappedRecords);
  }