public interface RecordInputSelector
RecordInput
objects.
This is typically used to implement operators which combine inputs without
any special regards to ordering. Care should be taken to try to service
all inputs equally to avoid introducing queue expansion.Modifier and Type | Method and Description |
---|---|
int |
readyIndex()
Gets the index of the currently ready input.
|
RecordInput |
readyInput()
Gets the currently ready input.
|
long |
readyTokens()
Gets the maximum number of tokens guaranteed available on the ready input.
|
boolean |
waitForReadyInput()
Waits until there is data available on one of the registered inputs.
|
boolean waitForReadyInput()
readyInput()
.
Waiting attempts to be fair. If waitForReadyInput
is invoked
while the currently ready input still has data, a new current input
will be found, if one is available.
false
is returned.int readyIndex()
-1
if no input is ready, as is the case
initially or after all inputs are at EOD.RecordInput readyInput()
waitForReadyInput()
,
it is guaranteed that the first call to stepNext()
on this input will
not block, although subsequent calls may.null
is returned if there is no input ready, as is the case
initially or after all inputs are at EOD.long readyTokens()
Copyright © 2024 Actian Corporation. All rights reserved.