Modifier and Type | Interface and Description |
---|---|
interface |
PullingAsyncDataInput<T>
Interface defining couple of essential methods for asynchronous and non blocking data polling.
|
Modifier and Type | Class and Description |
---|---|
static class |
AvailabilityProvider.AvailabilityHelper
A availability implementation for providing the helpful functions of resetting the
available/unavailable states.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RecordWriterDelegate<T extends IOReadableWritable>
The record writer delegate provides the availability function for task processor, and it might
represent a single
RecordWriter or multiple RecordWriter instances in specific
implementations. |
interface |
ResultPartitionWriter
A buffer-oriented runtime result writer API for producing results.
|
Modifier and Type | Class and Description |
---|---|
class |
BroadcastRecordWriter<T extends IOReadableWritable>
A special record-oriented runtime result writer only for broadcast mode.
|
class |
ChannelSelectorRecordWriter<T extends IOReadableWritable>
A regular record-oriented runtime result writer.
|
class |
MultipleRecordWriters<T extends IOReadableWritable>
The specific delegate implementation for the multiple outputs case.
|
class |
NonRecordWriter<T extends IOReadableWritable>
The specific delegate implementation for the non output case like sink task.
|
class |
RecordWriter<T extends IOReadableWritable>
An abstract record-oriented runtime result writer.
|
class |
SingleRecordWriter<T extends IOReadableWritable>
The specific delegate implementation for the single output case.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BufferPool
A dynamically sized buffer pool.
|
interface |
BufferProvider
A buffer provider to request buffers from in a synchronous or asynchronous fashion.
|
Modifier and Type | Class and Description |
---|---|
class |
NetworkBufferPool
The NetworkBufferPool is a fixed size pool of
MemorySegment instances for the network
stack. |
Modifier and Type | Class and Description |
---|---|
class |
ReleaseOnConsumptionResultPartition
ResultPartition that releases itself once all subpartitions have been consumed.
|
class |
ResultPartition
A result partition for data produced by a single task.
|
Modifier and Type | Class and Description |
---|---|
class |
IndexedInputGate
An
InputGate with a specific index. |
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 |
ConsumableNotifyingResultPartitionWriterDecorator
A wrapper of result partition writer for handling the logic of consumable notification.
|
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 | Class and Description |
---|---|
class |
SourceOperator<OUT,SplitT extends SourceSplit>
Base source operator only used for integrating the source reader which is proposed by FLIP-27.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PushingAsyncDataInput<T>
The variant of
PullingAsyncDataInput that is defined for handling both network input and
source input in a unified way via PushingAsyncDataInput.emitNext(DataOutput) instead of returning Optional.empty() via PullingAsyncDataInput.pollNext() . |
interface |
StreamInputProcessor
Interface for processing records by
StreamTask . |
interface |
StreamTaskInput<T>
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 |
StreamMultipleInputProcessor
Input processor for
MultipleInputStreamOperator . |
class |
StreamOneInputProcessor<IN>
Input reader for
OneInputStreamTask . |
class |
StreamTaskExternallyInducedSourceInput<T>
A subclass of
StreamTaskSourceInput for ExternallyInducedSourceReader . |
class |
StreamTaskNetworkInput<T>
Implementation of
StreamTaskInput that wraps an input from network taken from CheckpointedInputGate . |
class |
StreamTaskSourceInput<T>
Implementation of
StreamTaskInput that reads data from the SourceOperator and
returns the InputStatus to indicate whether the source state is available, unavailable or
finished. |
class |
StreamTwoInputProcessor<IN1,IN2>
Input reader for
TwoInputStreamTask . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.