Click or drag to resize

MultiRecordReaderT Class

Record reader that reads from multiple other record readers sequentially.
Inheritance Hierarchy
SystemObject
  Ookii.Jumbo.IORecordReaderT
    Ookii.Jumbo.IOMultiInputRecordReaderT
      Ookii.Jumbo.IOMultiRecordReaderT

Namespace:  Ookii.Jumbo.IO
Assembly:  Ookii.Jumbo (in Ookii.Jumbo.dll) Version: 2.0.0
Syntax
public sealed class MultiRecordReader<T> : MultiInputRecordReader<T>

Type Parameters

T
The type of the records.

The MultiRecordReaderT type exposes the following members.

Constructors
  NameDescription
Public methodMultiRecordReaderT
Initializes a new instance of the MultiRecordReaderT class.
Top
Properties
  NameDescription
Public propertyAllowRecordReuse
Gets a value that indicates that this record reader is allowed to reuse record instances.
(Inherited from MultiInputRecordReaderT.)
Public propertyBufferSize
Gets the buffer size to use to read input files.
(Inherited from MultiInputRecordReaderT.)
Public propertyBytesRead
Gets the actual number of bytes read from the input.
(Inherited from MultiInputRecordReaderT.)
Public propertyCompressionType
Gets the type of compression to use to read input files.
(Inherited from MultiInputRecordReaderT.)
Public propertyCurrentInputCount (Inherited from MultiInputRecordReaderT.)
Public propertyCurrentPartition
Gets or sets the partition that calls to ReadRecord should return records for.
(Inherited from MultiInputRecordReaderT.)
Public propertyCurrentRecord
Gets the current record.
(Inherited from RecordReaderT.)
Public propertyHasFinished
Gets a value indicating whether this instance has read all records.
(Inherited from RecordReaderT.)
Public propertyHasRecords
Gets a value that indicates whether there are records available on the data source that this reader is reading from.
(Inherited from RecordReaderT.)
Public propertyInputBytes
Gets the size of the records before deserialization of all record readers.
(Inherited from MultiInputRecordReaderT.)
Public propertyPartitionCount
Gets the number of partitions assigned to this reader.
(Inherited from MultiInputRecordReaderT.)
Public propertyPartitionNumbers
Gets the partition numbers assigned to this reader.
(Inherited from MultiInputRecordReaderT.)
Public propertyProgress
Gets the combined progress of the record readers.
(Inherited from MultiInputRecordReaderT.)
Public propertyReadTime
Gets the time spent reading.
(Inherited from RecordReaderT.)
Public propertyRecordsRead
Gets the number of records that has been read by this record reader.
(Inherited from RecordReaderT.)
Public propertySourceName
Gets or sets the an informational string indicating the source of the records.
(Inherited from RecordReaderT.)
Public propertyTimeWaiting
Gets the amount of time the record reader spent waiting for input to become available.
Public propertyTotalInputCount
Gets the total number of inputs readers that this record reader will have.
(Inherited from MultiInputRecordReaderT.)
Top
Methods
  NameDescription
Public methodAddInput
Adds the input.
(Overrides MultiInputRecordReaderTAddInput(IListRecordInput).)
Public methodAssignAdditionalPartitions
Assigns additional partitions to this record reader.
(Inherited from MultiInputRecordReaderT.)
Public methodDispose
Cleans up all resources held by this StreamRecordReader{T}.
(Inherited from RecordReaderT.)
Public methodEnumerateRecords
Enumerates over all the records.
(Inherited from RecordReaderT.)
Public methodEquals
Determines whether the specified object is equal to the current object.
(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.)
Public methodNextPartition
Moves the current partition to the next partition.
(Inherited from MultiInputRecordReaderT.)
Public methodReadRecord
Reads a record.
(Inherited from RecordReaderT.)
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Top
Events
See Also