THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||
|---|---|---|
| ||
/**
* ReturnReturns the stream-timemaximum timestamp of thisany partitionrecord groupyet definedprocessed asby the largest timestamp seen across all partitionstask.
*
* @return the stream-timemaximum timestamp of thisany partitionrecord groupyet definedprocessed asby the largest timestamp seen across all partitionstask
*/
long currentStreamTimeMs(); |
...
It is expected that this will return the StreamTask's time from the partition group. This stream time will be the maximum timestamp of any record yet processed by the task. This would provide the actual stream time because relying on the timestamp of records is not reliable when the records might not be processed in order of time.
...