private Map getIngestionPayloadMap()

in source/src/main/java/com/amazonaws/comprehend/esproxy/lambda/processor/BulkProcessor.java [152:164]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    private Map<Integer, BulkPayload> getIngestionPayloadMap(@NonNull final List<String> payloadList) {
        Map<Integer, BulkPayload> bulkPayloadMap = new HashMap<>();

        for (int rowNum = 0; rowNum < payloadList.size(); rowNum++) {
            Optional<String> indexName = RequestIdentifier.getBulkIndexName(payloadList.get(rowNum));
            if (indexName.isPresent() && (rowNum + 1 < payloadList.size())) {
                bulkPayloadMap.put(rowNum + 1,
                        new BulkPayload(indexName.get(), ingestionSerializer.deserialize(payloadList.get(rowNum + 1))));
                rowNum++; // Skip the checking for the next line
            }
        }
        return bulkPayloadMap;
    }