Uses of Class
org.apache.flink.streaming.runtime.streamstatus.StreamStatus

Packages that use StreamStatus

Package	Description
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.streamrecord
org.apache.flink.streaming.runtime.streamstatus
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

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

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

Modifier and Type	Method and Description
void	RecordWriterOutput.emitStreamStatus(StreamStatus streamStatus)

Uses of StreamStatus in org.apache.flink.streaming.runtime.streamrecord

Methods in org.apache.flink.streaming.runtime.streamrecord that return StreamStatus

Modifier and Type	Method and Description
StreamStatus	StreamElement.asStreamStatus() Casts this element into a StreamStatus.

Uses of StreamStatus in org.apache.flink.streaming.runtime.streamstatus

Fields in org.apache.flink.streaming.runtime.streamstatus declared as StreamStatus

Modifier and Type	Field and Description
static StreamStatus	StreamStatus.ACTIVE
static StreamStatus	StreamStatus.IDLE
protected StreamStatus	StatusWatermarkValve.InputChannelStatus.streamStatus

Methods in org.apache.flink.streaming.runtime.streamstatus that return StreamStatus

Modifier and Type	Method and Description
StreamStatus	StreamStatusProvider.getStreamStatus() Returns the current stream status.

Methods in org.apache.flink.streaming.runtime.streamstatus with parameters of type StreamStatus

Modifier and Type	Method and Description
void	StatusWatermarkValve.ValveOutputHandler.handleStreamStatus(StreamStatus streamStatus)
void	StatusWatermarkValve.inputStreamStatus(StreamStatus streamStatus, int channelIndex) Feed a StreamStatus into the valve.
void	StreamStatusMaintainer.toggleStreamStatus(StreamStatus streamStatus) Toggles the current stream status.

Uses of StreamStatus in org.apache.flink.streaming.runtime.tasks

Methods in org.apache.flink.streaming.runtime.tasks that return StreamStatus

Modifier and Type	Method and Description
StreamStatus	OperatorChain.getStreamStatus()

Methods in org.apache.flink.streaming.runtime.tasks with parameters of type StreamStatus

Modifier and Type	Method and Description
void	OperatorChain.toggleStreamStatus(StreamStatus status)