Click or drag to resize

TcpInputChannel Class

Represents the reading end of a TCP channel
Inheritance Hierarchy

Namespace:  Ookii.Jumbo.Jet.Channels
Assembly:  Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 2.0.0
Syntax
public class TcpInputChannel : InputChannel, 
	IHasMetrics

The TcpInputChannel type exposes the following members.

Constructors
  NameDescription
Public methodTcpInputChannel
Initializes a new instance of the TcpInputChannel class.
Top
Properties
  NameDescription
Public propertyActivePartitions
Gets the last set of partitions assigned to this channel.
(Inherited from InputChannel.)
Protected propertyCompressionType
Gets the compression type used by the channel.
(Inherited from InputChannel.)
Public propertyConfiguration
Gets the configuration of the input channel.
(Inherited from InputChannel.)
Protected propertyInputRecordType
Gets the type of the records create by the input task of this channel.
(Inherited from InputChannel.)
Public propertyInputStage
Gets the input stage of this channel.
(Inherited from InputChannel.)
Protected propertyInputTaskIds
Gets a collection of input task IDs.
(Inherited from InputChannel.)
Public propertyLocalBytesRead
Gets the number of bytes read from the local disk.
Public propertyLocalBytesWritten
Gets the number of bytes written to the local disk.
Public propertyMemoryStorageLevel
Gets the current memory storage usage level.
(Overrides InputChannelMemoryStorageLevel.)
Public propertyNetworkBytesRead
Gets the number of bytes read over the network.
Public propertyNetworkBytesWritten
Gets the number of bytes written over the network.
Protected propertyTaskExecution
Gets the task execution utility for the task that this channel provides input for.
(Inherited from InputChannel.)
Public propertyUsesMemoryStorage
Gets a value indicating whether the input channel uses memory storage to store inputs.
(Overrides InputChannelUsesMemoryStorage.)
Top
Methods
  NameDescription
Public methodAssignAdditionalPartitions
Assigns additional partitions to this input channel.
(Overrides InputChannelAssignAdditionalPartitions(IListInt32).)
Protected methodCreateChannelRecordReader
Creates a record reader of the type indicated by the channel.
(Inherited from InputChannel.)
Public methodCreateRecordReader (Overrides InputChannelCreateRecordReader.)
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Protected methodFinalize
Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object.)
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Protected methodMemberwiseClone
Creates a shallow copy of the current Object.
(Inherited from Object.)
Protected methodOnMemoryStorageFull
Raises the MemoryStorageFull event.
(Inherited from InputChannel.)
Public methodToString
Returns 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.
(Inherited from InputChannel.)
Top
See Also