The Datarate operator calculates the data rate in tuples per second. Use the operator where you want to measure the data rate.

 

/// Measure the data rate
drate = DATARATE({UPDATERATE = 1000}, previousOperator)