public static interface StatusWatermarkValve.ValveOutputHandler
StatusWatermarkValve
should implement a ValveOutputHandler
to handle watermark and stream status outputs from the valve.Modifier and Type | Method and Description |
---|---|
void |
handleStreamStatus(StreamStatus streamStatus) |
void |
handleWatermark(Watermark watermark) |
void handleWatermark(Watermark watermark)
void handleStreamStatus(StreamStatus streamStatus)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.