Click or drag to resize

InputChannel Class

Provides base functionality for IInputChannel implementations.
Inheritance Hierarchy

Namespace: Ookii.Jumbo.Jet.Channels
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
Syntax
Copy
public abstract class InputChannel : IInputChannel

The InputChannel type exposes the following members.

Constructors
 NameDescription
Protected methodInputChannel Initializes a new instance of the InputChannel class.
Top
Properties
 NameDescription
Public propertyActivePartitions Gets the last set of partitions assigned to this channel.
Protected propertyCompressionType Gets the compression type used by the channel.
Public propertyConfiguration Gets the configuration of the input channel.
Protected propertyInputRecordType Gets the type of the records create by the input task of this channel.
Public propertyInputStage Gets the input stage of this channel.
Protected propertyInputTaskIds Gets a collection of input task IDs.
Public propertyMemoryStorageLevel Gets the current memory storage usage level.
Protected propertyTaskExecution Gets the task execution utility for the task that this channel provides input for.
Public propertyUsesMemoryStorage Gets a value indicating whether the input channel uses memory storage to store inputs.
Top
Methods
 NameDescription
Public methodAssignAdditionalPartitions Assigns additional partitions to this input channel.
Protected methodCreateChannelRecordReader Creates a record reader of the type indicated by the channel.
Public methodCreateRecordReader Creates a RecordReaderT from which the channel can read its input.
Public methodEqualsDetermines whether the specified object is equal to the current object.
(Inherited from Object)
Protected methodFinalizeAllows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object)
Public methodGetHashCodeServes as the default hash function.
(Inherited from Object)
Public methodGetTypeGets the Type of the current instance.
(Inherited from Object)
Protected methodMemberwiseCloneCreates a shallow copy of the current Object.
(Inherited from Object)
Protected methodOnMemoryStorageFull Raises the MemoryStorageFull event.
Public methodToStringReturns a string that represents the current object.
(Inherited from Object)
Top
Events
 NameDescription
Public eventMemoryStorageFull Occurs when the input channel stalls waiting for space to become available in the memory storage.
Top
See Also