MultiInputRecordReaderTWaitForInputs Method

Waits until the specified number of inputs becomes available for all currently active partitions.

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

Syntax

C++

Copy

protected bool WaitForInputs(
	int inputCount,
	int timeout
)

Protected Function WaitForInputs ( 
	inputCount As Integer,
	timeout As Integer
) As Boolean

protected:
bool WaitForInputs(
	int inputCount, 
	int timeout
)

member WaitForInputs : 
        inputCount : int * 
        timeout : int -> bool

Parameters

inputCount Int32: The number of inputs to wait for.
timeout Int32: The maximum amount of time to wait, in milliseconds, or Infinite to wait indefinitely.

Return Value

Boolean
if a new input is available; if the timeout expired.

Remarks

This function will wait for the specified number of inputs on the last group of partitions assigned to the reader via AssignAdditionalPartitions(IListInt32).

Reference

MultiInputRecordReaderT Class

Ookii.Jumbo.IO Namespace