InputChannel Class |
Namespace: Ookii.Jumbo.Jet.Channels
The InputChannel type exposes the following members.
Name | Description | |
---|---|---|
InputChannel |
Initializes a new instance of the InputChannel class.
|
Name | Description | |
---|---|---|
ActivePartitions |
Gets the last set of partitions assigned to this channel.
| |
CompressionType |
Gets the compression type used by the channel.
| |
Configuration |
Gets the configuration of the input channel.
| |
InputRecordType |
Gets the type of the records create by the input task of this channel.
| |
InputStage |
Gets the input stage of this channel.
| |
InputTaskIds |
Gets a collection of input task IDs.
| |
MemoryStorageLevel |
Gets the current memory storage usage level.
| |
TaskExecution |
Gets the task execution utility for the task that this channel provides input for.
| |
UsesMemoryStorage |
Gets a value indicating whether the input channel uses memory storage to store inputs.
|
Name | Description | |
---|---|---|
AssignAdditionalPartitions |
Assigns additional partitions to this input channel.
| |
CreateChannelRecordReader |
Creates a record reader of the type indicated by the channel.
| |
CreateRecordReader |
Creates a RecordReaderT from which the channel can read its input.
| |
Equals | Determines whether the specified object is equal to the current object. (Inherited from Object.) | |
Finalize | Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.) | |
GetHashCode | Serves as the default hash function. (Inherited from Object.) | |
GetType | Gets the Type of the current instance. (Inherited from Object.) | |
MemberwiseClone | Creates a shallow copy of the current Object. (Inherited from Object.) | |
OnMemoryStorageFull |
Raises the MemoryStorageFull event.
| |
ToString | Returns a string that represents the current object. (Inherited from Object.) |
Name | Description | |
---|---|---|
MemoryStorageFull |
Occurs when the input channel stalls waiting for space to become available in the memory storage.
|