Uses of Package
org.apache.flink.api.common.eventtime
-
Classes in org.apache.flink.api.common.eventtime used by org.apache.flink.api.common.eventtime Class Description BoundedOutOfOrdernessWatermarks A WatermarkGenerator for situations where records are out of order, but you can place an upper bound on how far the events are out of order.IndexedCombinedWatermarkStatus Represents combined value and status of a watermark for a set number of input partial watermarks.SerializableTimestampAssigner ATimestampAssignerthat is alsoSerializable.TimestampAssigner ATimestampAssignerassigns event time timestamps to elements.TimestampAssignerSupplier A supplier forTimestampAssigners.TimestampAssignerSupplier.Context Additional information available toTimestampAssignerSupplier.createTimestampAssigner(Context).Watermark Watermarks are the progress indicators in the data streams.WatermarkAlignmentParams Configuration parameters for watermark alignment.WatermarkGenerator TheWatermarkGeneratorgenerates watermarks either based on events or periodically (in a fixed interval).WatermarkGeneratorSupplier A supplier forWatermarkGenerators.WatermarkGeneratorSupplier.Context Additional information available toWatermarkGeneratorSupplier.createWatermarkGenerator(Context).WatermarkOutput An output for watermarks.WatermarkOutputMultiplexer.WatermarkUpdateListener A callback for propagating changes to split based watermarks.WatermarkStrategy The WatermarkStrategy defines how to generateWatermarks in the stream sources. -
Classes in org.apache.flink.api.common.eventtime used by org.apache.flink.api.connector.sink Class Description Watermark Watermarks are the progress indicators in the data streams. -
Classes in org.apache.flink.api.common.eventtime used by org.apache.flink.api.connector.sink2 Class Description Watermark Watermarks are the progress indicators in the data streams. -
Classes in org.apache.flink.api.common.eventtime used by org.apache.flink.api.connector.source Class Description Watermark Watermarks are the progress indicators in the data streams.WatermarkOutput An output for watermarks.