Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ChannelSelector
The
ChannelSelector determines to which logical channels a record should be written to. |
RecordWriter
An abstract record-oriented runtime result writer.
|
RecordWriterBuilder
Utility class to encapsulate the logic of building a
RecordWriter instance. |
RecordWriterDelegate
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. |
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
SubtaskStateMapper
The
SubtaskStateMapper narrows down the subtasks that need to be read during rescaling to
recover from a particular subtask when in-flight data has been stored in the checkpoint. |
Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
SubtaskStateMapper
The
SubtaskStateMapper narrows down the subtasks that need to be read during rescaling to
recover from a particular subtask when in-flight data has been stored in the checkpoint. |
Class and Description |
---|
RecordWriter
An abstract record-oriented runtime result writer.
|
Class and Description |
---|
ChannelSelector
The
ChannelSelector determines to which logical channels a record should be written to. |
RecordWriter
An abstract record-oriented runtime result writer.
|
Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A record-oriented runtime result writer API for producing results.
|
Class and Description |
---|
RecordWriter
An abstract record-oriented runtime result writer.
|
Class and Description |
---|
ChannelSelector
The
ChannelSelector determines to which logical channels a record should be written to. |
SubtaskStateMapper
The
SubtaskStateMapper narrows down the subtasks that need to be read during rescaling to
recover from a particular subtask when in-flight data has been stored in the checkpoint. |
Class and Description |
---|
RecordWriterDelegate
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. |
Class and Description |
---|
ChannelSelector
The
ChannelSelector determines to which logical channels a record should be written to. |
SubtaskStateMapper
The
SubtaskStateMapper narrows down the subtasks that need to be read during rescaling to
recover from a particular subtask when in-flight data has been stored in the checkpoint. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.