Click or drag to resize

MultiInputRecordReaderTGetInputReader(Int32, Int32) Method

Returns the record reader for the specified partition and input.

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

Parameters

partition  Int32
The partition of the reader to return.
index  Int32
The index of the record reader to return.

Return Value

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