Package | Description |
---|---|
org.apache.flink.api.common.eventtime | |
org.apache.flink.api.connector.sink | |
org.apache.flink.api.connector.sink2 | |
org.apache.flink.api.connector.source | |
org.apache.flink.connector.testutils.source.reader | |
org.apache.flink.streaming.api.functions.sink | |
org.apache.flink.streaming.api.operators.source | |
org.apache.flink.streaming.connectors.kafka.internals | |
org.apache.flink.streaming.runtime.operators |
This package contains the operators that perform the stream transformations.
|
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 |
---|---|
default void |
SinkWriter.writeWatermark(Watermark watermark)
Deprecated.
Add a watermark to the writer.
|
Modifier and Type | Method and Description |
---|---|
default void |
SinkWriter.writeWatermark(Watermark watermark)
Adds a watermark to the writer.
|
Modifier and Type | Method and Description |
---|---|
void |
ReaderOutput.emitWatermark(Watermark watermark)
Emits the given watermark.
|
Modifier and Type | Method and Description |
---|---|
void |
TestingReaderOutput.emitWatermark(Watermark watermark) |
void |
SourceReaderTestBase.ValidatingSourceOutput.emitWatermark(Watermark watermark) |
Modifier and Type | Method and Description |
---|---|
default void |
SinkFunction.writeWatermark(Watermark watermark)
Writes the given watermark to the sink.
|
Modifier and Type | Method and Description |
---|---|
void |
WatermarkToDataOutput.emitWatermark(Watermark watermark) |
void |
SourceOutputWithWatermarks.emitWatermark(Watermark watermark) |
Modifier and Type | Method and Description |
---|---|
void |
SourceContextWatermarkOutputAdapter.emitWatermark(Watermark watermark) |
Modifier and Type | Method and Description |
---|---|
void |
TimestampsAndWatermarksOperator.WatermarkEmitter.emitWatermark(Watermark watermark) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.