Modifier and Type | Method and Description |
---|---|
InputStatus |
SourceReader.pollNext(ReaderOutput<T> output)
Poll the next available record into the
SourceOutput . |
Modifier and Type | Method and Description |
---|---|
InputStatus |
IteratorSourceReader.pollNext(ReaderOutput<E> output) |
Modifier and Type | Method and Description |
---|---|
InputStatus |
SourceReaderBase.pollNext(ReaderOutput<T> output) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
InputStatus |
SourceOperator.emitNext(PushingAsyncDataInput.DataOutput<OUT> output) |
Modifier and Type | Method and Description |
---|---|
InputStatus |
MultipleInputSelectionHandler.calculateOverallStatus() |
InputStatus |
StreamTaskNetworkInput.emitNext(PushingAsyncDataInput.DataOutput<T> output) |
InputStatus |
StreamTaskExternallyInducedSourceInput.emitNext(PushingAsyncDataInput.DataOutput<T> output) |
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 |
StreamTwoInputProcessor.processInput() |
InputStatus |
StreamMultipleInputProcessor.processInput() |
InputStatus |
StreamInputProcessor.processInput() |
InputStatus |
StreamOneInputProcessor.processInput() |
InputStatus |
MultipleInputSelectionHandler.updateStatus(InputStatus inputStatus,
int inputIndex) |
Modifier and Type | Method and Description |
---|---|
InputStatus |
MultipleInputSelectionHandler.updateStatus(InputStatus inputStatus,
int inputIndex) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.