MultiPartitionRecordReaderT Class

Record reader used for pull tasks with the ProcessAllInputPartitionsAttribute attribute.

Inheritance Hierarchy

SystemObject
Ookii.Jumbo.IORecordReaderT
Ookii.Jumbo.JetMultiPartitionRecordReaderT

Namespace: Ookii.Jumbo.Jet
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1

Syntax

C++

Copy

public sealed class MultiPartitionRecordReader<T> : RecordReader<T>

Public NotInheritable Class MultiPartitionRecordReader(Of T)
	Inherits RecordReader(Of T)

generic<typename T>
public ref class MultiPartitionRecordReader sealed : public RecordReader<T>

[<SealedAttribute>]
type MultiPartitionRecordReader<'T> = 
    class
        inherit RecordReader<'T>
    end

Type Parameters

T: The type of the records.

The MultiPartitionRecordReaderT type exposes the following members.

Constructors

	Name	Description
	MultiPartitionRecordReaderT	Initializes a new instance of the MultiPartitionRecordReaderT class.

Top

Properties

	Name	Description
	AllowAdditionalPartitions	Gets or sets a value indicating whether the task may request additional partitions from the job server if it finishes the current ones.
	BytesRead	Gets the actual number of bytes read from the input. (Inherited from RecordReaderT)
	CurrentPartition	Gets the partition of the current record.
	CurrentRecord	Gets the current record. (Inherited from RecordReaderT)
	HasFinished	Gets a value indicating whether this instance has read all records. (Inherited from RecordReaderT)
	HasRecords	Gets a value that indicates whether there are records available on the data source that this reader is reading from. (Inherited from RecordReaderT)
	InputBytes	Gets the size of the records before deserialization. (Inherited from RecordReaderT)
	PartitionCount	Gets the total number of partitions.
	Progress	Gets a number between 0 and 1 that indicates the progress of the reader. (Overrides RecordReaderTProgress)
	ReadTime	Gets the time spent reading. (Inherited from RecordReaderT)
	RecordsRead	Gets the number of records that has been read by this record reader. (Inherited from RecordReaderT)
	SourceName	Gets or sets the an informational string indicating the source of the records. (Inherited from RecordReaderT)
	StopAtEndOfPartition	Gets or sets a value indicating whether reading records will halt at the end of the current partition.

Top

Methods

	Name	Description
	Dispose	Cleans up all resources held by this StreamRecordReader{T}. (Inherited from RecordReaderT)
	EnumerateRecords	Enumerates over all the records. (Inherited from RecordReaderT)
	Equals	Determines whether the specified object is equal to the current object. (Inherited from Object)
	GetHashCode	Serves as the default hash function. (Inherited from Object)
	GetType	Gets the Type of the current instance. (Inherited from Object)
	ReadRecord	Reads a record. (Inherited from RecordReaderT)
	ToString	Returns a string that represents the current object. (Inherited from Object)

Top

Events

	Name	Description
	HasRecordsChanged	Occurs when the value of the HasRecords property changes. (Inherited from RecordReaderT)

Top

Remarks

A pull task with the ProcessAllInputPartitionsAttribute attribute may try to cast its input record reader to this type to retrieve information about the number of partitions and the current partition.

However, if the input to a pull task with the ProcessAllInputPartitionsAttribute attribute is not a channel with multiple partitions per task, the input record reader will not be a MultiPartitionRecordReaderT so you should not assume that such a cast will always succeed.

Reference

Ookii.Jumbo.Jet Namespace