Uses of Interface
org.apache.flink.streaming.runtime.io.PushingAsyncDataInput.DataOutput

Packages that use PushingAsyncDataInput.DataOutput

Package	Description
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.sort
org.apache.flink.streaming.api.operators.source
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.runtime.watermarkstatus

Uses of PushingAsyncDataInput.DataOutput in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators with parameters of type PushingAsyncDataInput.DataOutput

Modifier and Type	Method	Description
DataInputStatus	SourceOperator.emitNext(PushingAsyncDataInput.DataOutput<OUT> output)

Uses of PushingAsyncDataInput.DataOutput in org.apache.flink.streaming.api.operators.sort

Methods in org.apache.flink.streaming.api.operators.sort with parameters of type PushingAsyncDataInput.DataOutput

Modifier and Type	Method	Description
DataInputStatus	MultiInputSortingDataInput.emitNext(PushingAsyncDataInput.DataOutput<IN> output)
DataInputStatus	SortingDataInput.emitNext(PushingAsyncDataInput.DataOutput<T> output)

Uses of PushingAsyncDataInput.DataOutput in org.apache.flink.streaming.api.operators.source

Methods in org.apache.flink.streaming.api.operators.source with parameters of type PushingAsyncDataInput.DataOutput

Modifier and Type	Method	Description
ReaderOutput<T>	NoOpTimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output, TimestampsAndWatermarks.WatermarkUpdateListener watermarkEmitted)
ReaderOutput<T>	ProgressiveTimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output, TimestampsAndWatermarks.WatermarkUpdateListener watermarkUpdateListener)
ReaderOutput<T>	TimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output, TimestampsAndWatermarks.WatermarkUpdateListener watermarkCallback)	Creates the ReaderOutput for the source reader, than internally runs the timestamp extraction and watermark generation.
static <E> SourceOutputWithWatermarks<E>	SourceOutputWithWatermarks.createWithSeparateOutputs(PushingAsyncDataInput.DataOutput<E> recordsOutput, WatermarkOutput onEventWatermarkOutput, WatermarkOutput periodicWatermarkOutput, TimestampAssigner<E> timestampAssigner, WatermarkGenerator<E> watermarkGenerator)	Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and watermarks to the different WatermarkOutputs.

Constructors in org.apache.flink.streaming.api.operators.source with parameters of type PushingAsyncDataInput.DataOutput

Constructor	Description
SourceOutputWithWatermarks(PushingAsyncDataInput.DataOutput<T> recordsOutput, WatermarkOutput onEventWatermarkOutput, WatermarkOutput periodicWatermarkOutput, TimestampAssigner<T> timestampAssigner, WatermarkGenerator<T> watermarkGenerator)	Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and watermarks to the (possibly different) WatermarkOutput.
WatermarkToDataOutput(PushingAsyncDataInput.DataOutput<?> output)
WatermarkToDataOutput(PushingAsyncDataInput.DataOutput<?> output, TimestampsAndWatermarks.WatermarkUpdateListener watermarkEmitted)	Creates a new WatermarkOutput against the given DataOutput.

Uses of PushingAsyncDataInput.DataOutput in org.apache.flink.streaming.runtime.io

Classes in org.apache.flink.streaming.runtime.io that implement PushingAsyncDataInput.DataOutput

Modifier and Type	Class	Description
class	FinishedDataOutput<IN>	An empty PushingAsyncDataInput.DataOutput which is used by StreamOneInputProcessor once an DataInputStatus.END_OF_DATA is received.

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

Modifier and Type	Method	Description
DataInputStatus	AbstractStreamTaskNetworkInput.emitNext(PushingAsyncDataInput.DataOutput<T> output)
DataInputStatus	PushingAsyncDataInput.emitNext(PushingAsyncDataInput.DataOutput<T> output)	Pushes elements to the output from current data input, and returns the input status to indicate whether there are more available data in current input.
DataInputStatus	StreamTaskExternallyInducedSourceInput.emitNext(PushingAsyncDataInput.DataOutput<T> output)
DataInputStatus	StreamTaskSourceInput.emitNext(PushingAsyncDataInput.DataOutput<T> output)
void	RecordAttributesCombiner.inputRecordAttributes(RecordAttributes recordAttributes, int channelIdx, PushingAsyncDataInput.DataOutput<?> output)

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

Constructor	Description
StreamOneInputProcessor(StreamTaskInput<IN> input, PushingAsyncDataInput.DataOutput<IN> output, BoundedMultiInput endOfInputAware)

Uses of PushingAsyncDataInput.DataOutput in org.apache.flink.streaming.runtime.tasks

Classes in org.apache.flink.streaming.runtime.tasks that implement PushingAsyncDataInput.DataOutput

Modifier and Type	Class	Description
static class	SourceOperatorStreamTask.AsyncDataOutputToOutput<T>	Implementation of PushingAsyncDataInput.DataOutput that wraps a specific Output.

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

Modifier and Type	Method	Description
DataInputStatus	StreamTaskFinishedOnRestoreSourceInput.emitNext(PushingAsyncDataInput.DataOutput<T> output)

Uses of PushingAsyncDataInput.DataOutput in org.apache.flink.streaming.runtime.watermarkstatus

Methods in org.apache.flink.streaming.runtime.watermarkstatus with parameters of type PushingAsyncDataInput.DataOutput

Modifier and Type	Method	Description
void	StatusWatermarkValve.inputWatermark(Watermark watermark, int channelIndex, PushingAsyncDataInput.DataOutput<?> output)	Feed a Watermark into the valve.
void	StatusWatermarkValve.inputWatermarkStatus(WatermarkStatus watermarkStatus, int channelIndex, PushingAsyncDataInput.DataOutput<?> output)	Feed a WatermarkStatus into the valve.