Modifier and Type | Interface and Description |
---|---|
interface |
AsyncDataInput<T>
Interface defining couple of essential methods for asynchronous and non blocking data polling.
|
interface |
NullableAsyncDataInput<T>
The variant of
AsyncDataInput that for performance reasons returns null from
NullableAsyncDataInput.pollNextNullable() instead returning Optional.empty() from
AsyncDataInput.pollNext() . |
Modifier and Type | Class and Description |
---|---|
class |
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
class |
SingleInputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
class |
UnionInputGate
Input gate wrapper to union the input from multiple input gates.
|
Modifier and Type | Class and Description |
---|---|
class |
InputGateWithMetrics
This class wraps
InputGate provided by shuffle service and it is mainly
used for increasing general input metrics from TaskIOMetricGroup . |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamTaskInput
Basic interface for inputs of stream operators.
|
Modifier and Type | Class and Description |
---|---|
class |
CheckpointedInputGate
The
CheckpointedInputGate uses CheckpointBarrierHandler to handle incoming
CheckpointBarrier from the InputGate . |
class |
StreamTaskNetworkInput
Implementation of
StreamTaskInput that wraps an input from network taken from CheckpointedInputGate . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.