Package | Description |
---|---|
org.apache.flink.streaming.runtime.io |
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) |
InputStatus |
StreamTwoInputProcessor.processInput() |
InputStatus |
StreamOneInputProcessor.processInput() |
InputStatus |
StreamInputProcessor.processInput() |
static InputStatus |
InputStatus.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static InputStatus[] |
InputStatus.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.