Uses of Class
org.apache.flink.streaming.runtime.watermarkstatus.StatusWatermarkValve

Packages that use StatusWatermarkValve

Package	Description
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.recovery

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

Fields in org.apache.flink.streaming.runtime.io declared as StatusWatermarkValve

Modifier and Type	Field	Description
protected StatusWatermarkValve	AbstractStreamTaskNetworkInput.statusWatermarkValve	Valve that controls how watermarks and watermark statuses are forwarded.

Methods in org.apache.flink.streaming.runtime.io with parameters of type StatusWatermarkValve

Modifier and Type	Method	Description
static <T> StreamTaskInput<T>	StreamTaskNetworkInputFactory.create(CheckpointedInputGate checkpointedInputGate, org.apache.flink.api.common.typeutils.TypeSerializer<T> inputSerializer, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, StatusWatermarkValve statusWatermarkValve, int inputIndex, org.apache.flink.runtime.checkpoint.InflightDataRescalingDescriptor rescalingDescriptorinflightDataRescalingDescriptor, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners, org.apache.flink.api.common.TaskInfo taskInfo, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)	Factory method for StreamTaskNetworkInput or RescalingStreamTaskNetworkInput depending on InflightDataRescalingDescriptor.

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

Constructor	Description
AbstractStreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate, org.apache.flink.api.common.typeutils.TypeSerializer<T> inputSerializer, StatusWatermarkValve statusWatermarkValve, int inputIndex, Map<org.apache.flink.runtime.checkpoint.channel.InputChannelInfo,R> recordDeserializers, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)
StreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate, org.apache.flink.api.common.typeutils.TypeSerializer<T> inputSerializer, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, StatusWatermarkValve statusWatermarkValve, int inputIndex, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)

Uses of StatusWatermarkValve in org.apache.flink.streaming.runtime.io.recovery

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

Constructor

Description

RescalingStreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate, org.apache.flink.api.common.typeutils.TypeSerializer<T> inputSerializer, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, StatusWatermarkValve statusWatermarkValve, int inputIndex, org.apache.flink.runtime.checkpoint.InflightDataRescalingDescriptor inflightDataRescalingDescriptor, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners, org.apache.flink.api.common.TaskInfo taskInfo, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)