Uses of Class
org.apache.flink.streaming.api.operators.source.SourceOutputWithWatermarks

Packages that use SourceOutputWithWatermarks

Package	Description
org.apache.flink.streaming.api.operators.source

Uses of SourceOutputWithWatermarks in org.apache.flink.streaming.api.operators.source

Methods in org.apache.flink.streaming.api.operators.source that return SourceOutputWithWatermarks

Modifier and Type	Method and Description
static <E> SourceOutputWithWatermarks<E>	SourceOutputWithWatermarks.createWithSameOutputs(PushingAsyncDataInput.DataOutput<E> recordsAndWatermarksOutput, TimestampAssigner<E> timestampAssigner, WatermarkGenerator<E> watermarkGenerator) Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and watermarks to the (possibly different) WatermarkOutput.
static <E> SourceOutputWithWatermarks<E>	SourceOutputWithWatermarks.createWithSeparateOutputs(PushingAsyncDataInput.DataOutput<E> recordsOutput, WatermarkOutput onEventWatermarkOutput, WatermarkOutput periodicWatermarkOutput, TimestampAssigner<E> timestampAssigner, WatermarkGenerator<E> watermarkGenerator) Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and watermarks to the different WatermarkOutputs.