Modifier and Type | Field and Description |
---|---|
static Watermark |
Watermark.MAX_WATERMARK
The watermark that signifies end-of-event-time.
|
Modifier and Type | Method and Description |
---|---|
void |
WatermarkOutput.emitWatermark(Watermark watermark)
Emits the given watermark.
|
Modifier and Type | Method and Description |
---|---|
void |
ReaderOutput.emitWatermark(Watermark watermark)
Emits the given watermark.
|
Modifier and Type | Method and Description |
---|---|
void |
SourceOutputWithWatermarks.emitWatermark(Watermark watermark) |
void |
WatermarkToDataOutput.emitWatermark(Watermark watermark) |
Modifier and Type | Method and Description |
---|---|
void |
SourceContextWatermarkOutputAdapter.emitWatermark(Watermark watermark) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.