Package | Description |
---|---|
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.streamstatus |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataOutput<T>
Base class for all data outputs.
|
Modifier and Type | Method and Description |
---|---|
InputStatus |
PushingAsyncDataInput.emitNext(PushingAsyncDataInput.DataOutput<T> output)
Pushes the next element to the output from current data input, and returns
the input status to indicate whether there are more available data in
current input.
|
InputStatus |
StreamTaskSourceInput.emitNext(PushingAsyncDataInput.DataOutput<T> output) |
InputStatus |
StreamTaskNetworkInput.emitNext(PushingAsyncDataInput.DataOutput<T> output) |
Constructor and Description |
---|
StreamOneInputProcessor(StreamTaskInput<IN> input,
PushingAsyncDataInput.DataOutput<IN> output,
Object lock,
OperatorChain<?,?> operatorChain) |
Constructor and Description |
---|
StatusWatermarkValve(int numInputChannels,
PushingAsyncDataInput.DataOutput output)
Returns a new
StatusWatermarkValve . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.