Click or drag to resize

MultiInputRecordReaderTGetInputReader Method (Int32, Int32)

Returns the record reader for the specified partition and input.

Namespace:  Ookii.Jumbo.IO
Assembly:  Ookii.Jumbo (in Ookii.Jumbo.dll) Version: 2.0.0
Syntax
protected IRecordReader GetInputReader(
	int partition,
	int index
)

Parameters

partition
Type: SystemInt32
The partition of the reader to return.
index
Type: SystemInt32
The index of the record reader to return.

Return Value

Type: IRecordReader
An instance of a class implementing IRecordReader for the specified input.
Remarks

Once a call to GetInputReader(Int32, Int32) has returned an input, subsequent calls with the same partition and index are guaranteed to return the same value.

Two calls to GetInputReader(Int32, Int32) with the same index but a different partition aren't guaranteed to return inputs from the same source.

See Also