Click or drag to resize

MultiInputRecordReaderTGetInputReader(Int32, Int32, Boolean) 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,
	bool memoryOnly
)

Parameters

partition  Int32
The partition of the reader to return.
index  Int32
The index of the record reader to return.
memoryOnly  Boolean
to return only inputs that are stored in memory; otherwise, .

Return Value

IRecordReader
An instance of a class implementing IRecordReader for the specified input, or if memoryOnly was and the input was not stored in memory.
Remarks

Because the MultiInputRecordReaderT tries to keep the inputs that in memory in front of the inputs that aren't, if a call to GetInputReader(Int32, Int32, Boolean) returned , subsequent calls with the same partition and index might not return .

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

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

See Also