 | Ookii. |
Provides the implementation of File, Pipeline and TCP channels, as well as the sorting implementation used by channels using SpillSort.
Classes| Class | Description | |
|---|---|---|
 | ChannelConfiguration | Represents configuration information about a channel through which two tasks communicate. |
| ChannelException | Exception that is thrown if an error occurs in the TCP or file channel. |
| FileInputChannel | Represents the reading end of a file channel. |
| FileOutputChannel | Represents the writing end of a file channel between two tasks. |
| InputChannel | Provides base functionality for IInputChannel implementations. |
| MemoryStorageFullEventArgs | Provides data for the MemoryStorageFull event. |
| OutputChannel | Provides base functionality for IOutputChannel implementations. |
| PartitionFileIndex | Index data for partition files. For Jumbo internal use only. |
| PartitionFileIndexEntryValueWriter | Value writer for the PartitionFileIndexEntry structure. |
| PipelineOutputChannel | Represents the the channel between two pipelined tasks. |
| SortSpillRecordWriterT | Multi record writer that collects the records in an in-memory buffer, and periodically spills the records to disk when the buffer is full. The final output is sorted. |
| SpillRecordWriterT | Multi record writer that collects records in an in-memory buffer, and periodically spills the record to the output when the buffer is full. |
| TcpInputChannel | Represents the reading end of a TCP channel |
| TcpOutputChannel | Represents the writing end of a TCP channel between two tasks. |
Structures| Structure | Description | |
|---|---|---|
 | PartitionFileIndexEntry | Index entry for a partition file. For Jumbo internal use only. |
Interfaces| Interface | Description | |
|---|---|---|
 | IChannelMultiInputRecordReader | Interface used by multi input record readers that read data from a channel. |
| IInputChannel | Interface for input channels for task communication. |
| IOutputChannel | Interface for output channels for task communication. |
Enumerations| Enumeration | Description | |
|---|---|---|
 | ChannelType | The type of a communication channel between two tasks. |
| FileChannelOutputType | Indicates how the FileOutputChannel writes intermediate data to the disk. |
| PartitionAssignmentMethod | Indicates how initial partition assignment is done if the channel has multiple partitions per task. |
| SpillRecordWriterOptions | Flags controlling the behavior of the SpillRecordWriterT. |