This processor calculates the duration for a given stream with a start timestamp and an end timestamp.
Two timestamp fields
Appends a new field with the difference of t2 and t1