Stream Correlation

if (left == null || right == null) {
    // Fixed cost for leaving a record unmatched.
    return 20 * 60.0;
}

double cost = 0.0;

long timestampLeft =
    left.timestamp.toEpochSecond(java.time.ZoneOffset.UTC);
long timestampRight =
    right.timestamp.toEpochSecond(java.time.ZoneOffset.UTC);

// Increase the cost according to the timestamp difference.
cost += Math.abs(timestampLeft - timestampRight);

// Increase the cost according to the duration difference.
cost += Math.abs(left.duration - right.duration);

return cost;

if (left == null || right == null) {
    return; // No match was found.
}

// Copy the backend transaction identifier to the UX request.
left.backendSequence = right.sequence;

// Save the updated UX request.
processor.updateFact(left);