import java.util.stream.Collectors;
import java.util.stream.IntStream;
-import org.onap.dcae.analytics.model.AnalyticsModelConstants;
import org.onap.dcae.analytics.tca.core.service.GenericTcaExecutionContext;
import org.onap.dcae.analytics.tca.core.service.GenericTcaProcessingContext;
import org.onap.dcae.analytics.tca.core.service.GenericTcaResultContext;
return IntStream.range(0, cefMessages.size())
// generate initial Processing contexts
.mapToObj(cefMessageIndex -> GenericTcaExecutionContext.builder()
- .requestId(executionRequestId +
- AnalyticsModelConstants.ANALYTICS_REQUEST_ID_DELIMITER + cefMessageIndex)
+ .requestId(executionRequestId)
.transactionId(executionTransactionId)
.messageIndex(cefMessageIndex)
.cefMessage(cefMessages.get(cefMessageIndex))