Uses of Class
org.apache.flink.streaming.runtime.metrics.WatermarkGauge

Packages that use WatermarkGauge

Package	Description
org.apache.flink.streaming.api.collector.selector
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.metrics

Uses of WatermarkGauge in org.apache.flink.streaming.api.collector.selector

Fields in org.apache.flink.streaming.api.collector.selector declared as WatermarkGauge

Modifier and Type	Field and Description
protected WatermarkGauge	DirectedOutput.watermarkGauge

Uses of WatermarkGauge in org.apache.flink.streaming.runtime.io

Constructors in org.apache.flink.streaming.runtime.io with parameters of type WatermarkGauge

Constructor and Description
StreamInputProcessor(org.apache.flink.runtime.io.network.partition.consumer.InputGate[] inputGates, org.apache.flink.api.common.typeutils.TypeSerializer<IN> inputSerializer, StreamTask<?,?> checkpointedTask, CheckpointingMode checkpointMode, Object lock, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.configuration.Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, OneInputStreamOperator<IN,?> streamOperator, org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup metrics, WatermarkGauge watermarkGauge)
StreamTwoInputProcessor(Collection<org.apache.flink.runtime.io.network.partition.consumer.InputGate> inputGates1, Collection<org.apache.flink.runtime.io.network.partition.consumer.InputGate> inputGates2, org.apache.flink.api.common.typeutils.TypeSerializer<IN1> inputSerializer1, org.apache.flink.api.common.typeutils.TypeSerializer<IN2> inputSerializer2, TwoInputStreamTask<IN1,IN2,?> checkpointedTask, CheckpointingMode checkpointMode, Object lock, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.configuration.Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup metrics, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge)

Uses of WatermarkGauge in org.apache.flink.streaming.runtime.metrics

Constructors in org.apache.flink.streaming.runtime.metrics with parameters of type WatermarkGauge

Constructor and Description
MinWatermarkGauge(WatermarkGauge watermarkGauge1, WatermarkGauge watermarkGauge2)