![]() | Ookii.Jumbo.Jet.Channels Namespace |
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.
|
Structure | Description | |
---|---|---|
![]() | PartitionFileIndexEntry |
Index entry for a partition file. For Jumbo internal use only.
|
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.
|
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.
|