Class | Description |
---|---|
MiniBatchAssignerOperator |
A stream operator that emits mini-batch marker in a given period.
|
MiniBatchedWatermarkAssignerOperator |
A stream operator that extracts timestamps from stream elements and
generates watermarks with specified emit latency.
|
WatermarkAssignerOperator |
A stream operator that extracts timestamps from stream elements and
generates periodic watermarks.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.