create_data_reducer

create_data_reducer(join: Callable) → Callable

Return a function that creates a new TimestampedData object containing the result of executing the given operation on two TimestampedData objects.

The use case for this function is actually quite simple: perform an operation on two TimestampedData objects (add, subtract, etc.) and put the result in a new TimestampedData object.

The resulting TimestampedData object has a creation time equal to that of the oldest input object.

Parameters:

join -- The function to call on the two input objects.

Returns:

Function that creates a TimestampedData object containing result of executing given join operation on two TimestampedData objects, with creation time equal to that of the oldest input object.