如何檢索和自定義數據流中的水印？

Question

我不確定這是否被認爲是最佳實踐，但我試圖找出一種方法來定製Dataflow的水印。類似於Flink的assignTimestampsAndWatermarks()。

我知道timestampBy()，我希望能夠檢索當前的水印並應用一些額外的依賴於它的邏輯。但我似乎無法找到任何方式來檢索當前的水印。

Answer 1

在MillWhell中，有一種方法可以基於源實現以編程方式定義自己的水印，但DataFlow具有自己的實現來決定水印。如果你正在定義你自己的自定義輸入是你可以實現邏輯來考慮你的源實現來獲得水印。