Click or drag to resize

MultiInputRecordReaderTGetInputReader Method (Int32, Int32, Boolean)

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
Copy
protected IRecordReader GetInputReader(
	int partition,
	int index,
	bool memoryOnly
)

Parameters

partition
Type: SystemInt32
The partition of the reader to return.
index
Type: SystemInt32
The index of the record reader to return.
memoryOnly
Type: SystemBoolean
to return only inputs that are stored in memory; otherwise, .

Return Value

Type: 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