T
- The type of the elements that can be emitted.public static interface OperatorChain.WatermarkGaugeExposingOutput<T> extends Output<T>
Output
that measures the last emitted watermark with a WatermarkGauge
.Modifier and Type | Method and Description |
---|---|
Gauge<Long> |
getWatermarkGauge() |
collect, emitLatencyMarker, emitWatermark
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.