Class and Description |
---|
ResultPartitionWriter
A buffer-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A buffer-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 buffer-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A buffer-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A buffer-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. |
RecordWriter
An abstract record-oriented runtime result writer.
|
Class and Description |
---|
ResultPartitionWriter
A buffer-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A buffer-oriented runtime result writer API for producing results.
|
Class and Description |
---|
ResultPartitionWriter
A buffer-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. |
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. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.