Ookii.Jumbo.Jet.Channels Namespace

Represents configuration information about a channel through which two tasks communicate.

Exception that is thrown if an error occurs in the TCP or file channel.

Represents the reading end of a file channel.

Represents the writing end of a file channel between two tasks.

Provides base functionality for IInputChannel implementations.

Provides data for the MemoryStorageFull event.

Provides base functionality for IOutputChannel implementations.

Index data for partition files. For Jumbo internal use only.

Value writer for the PartitionFileIndexEntry structure.

Represents the the channel between two pipelined tasks.

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.

Multi record writer that collects records in an in-memory buffer, and periodically spills the record to the output when the buffer is full.

Represents the reading end of a TCP channel

Represents the writing end of a TCP channel between two tasks.

Index entry for a partition file. For Jumbo internal use only.

Interface used by multi input record readers that read data from a channel.

Interface for input channels for task communication.

Interface for output channels for task communication.

The type of a communication channel between two tasks.

Indicates how the FileOutputChannel writes intermediate data to the disk.

Indicates how initial partition assignment is done if the channel has multiple partitions per task.

Flags controlling the behavior of the SpillRecordWriterT.