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 and 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 and Description

static <T> StreamTaskInput<T>

StreamTaskNetworkInputFactory.create(CheckpointedInputGate checkpointedInputGate, TypeSerializer<T> inputSerializer, IOManager ioManager, StatusWatermarkValve statusWatermarkValve, int inputIndex, InflightDataRescalingDescriptor rescalingDescriptorinflightDataRescalingDescriptor, Function<Integer,StreamPartitioner<?>> gatePartitioners, 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 and Description
AbstractStreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate, TypeSerializer<T> inputSerializer, StatusWatermarkValve statusWatermarkValve, int inputIndex, Map<InputChannelInfo,R> recordDeserializers, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)
StreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate, TypeSerializer<T> inputSerializer, 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 and Description
RescalingStreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate, TypeSerializer<T> inputSerializer, IOManager ioManager, StatusWatermarkValve statusWatermarkValve, int inputIndex, InflightDataRescalingDescriptor inflightDataRescalingDescriptor, Function<Integer,StreamPartitioner<?>> gatePartitioners, TaskInfo taskInfo, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)