Package org.teiid.dqp.internal.process
Class DataTierTupleSource
- java.lang.Object
-
- org.teiid.dqp.internal.process.DataTierTupleSource
-
- All Implemented Interfaces:
TupleSource
,DQPCore.CompletionListener<AtomicResultsMessage>
public class DataTierTupleSource extends Object implements TupleSource, DQPCore.CompletionListener<AtomicResultsMessage>
This tuple source impl can only be used once; once it is closed, it cannot be reopened and reused. TODO: the handling of DataNotAvailable is awkward. In the multi-threaded case we'd like to not even notify the parent plan and just schedule the next poll.
-
-
Constructor Summary
Constructors Constructor Description DataTierTupleSource(AtomicRequestMessage aqr, RequestWorkItem workItem, ConnectorWork cwi, DataTierManagerImpl dtm, int limit)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancelRequest()
void
closeSource()
Closes the Tuple Source.void
fullyCloseSource()
AtomicRequestMessage
getAtomicRequestMessage()
String
getConnectorName()
Future<Void>
getScheduledFuture()
boolean
isCanceled()
boolean
isDone()
boolean
isExplicitClose()
boolean
isQueued()
boolean
isRunning()
boolean
isTransactional()
List<?>
nextTuple()
Returns the next tuplevoid
onCompletion(FutureWork<AtomicResultsMessage> future)
-
-
-
Constructor Detail
-
DataTierTupleSource
public DataTierTupleSource(AtomicRequestMessage aqr, RequestWorkItem workItem, ConnectorWork cwi, DataTierManagerImpl dtm, int limit)
-
-
Method Detail
-
nextTuple
public List<?> nextTuple() throws TeiidComponentException, TeiidProcessingException
Description copied from interface:TupleSource
Returns the next tuple- Specified by:
nextTuple
in interfaceTupleSource
- Returns:
- the next tuple (a List object), or
null
if there are no more tuples. - Throws:
TeiidComponentException
- indicating a non-business exception such as a communication exception, or other such nondeterministic exceptionTeiidProcessingException
-
isQueued
public boolean isQueued()
-
isDone
public boolean isDone()
-
isRunning
public boolean isRunning()
-
fullyCloseSource
public void fullyCloseSource()
-
isCanceled
public boolean isCanceled()
-
cancelRequest
public void cancelRequest()
-
closeSource
public void closeSource()
Description copied from interface:TupleSource
Closes the Tuple Source.- Specified by:
closeSource
in interfaceTupleSource
- See Also:
TupleSource.closeSource()
-
getAtomicRequestMessage
public AtomicRequestMessage getAtomicRequestMessage()
-
getConnectorName
public String getConnectorName()
-
isTransactional
public boolean isTransactional()
-
onCompletion
public void onCompletion(FutureWork<AtomicResultsMessage> future)
- Specified by:
onCompletion
in interfaceDQPCore.CompletionListener<AtomicResultsMessage>
-
isExplicitClose
public boolean isExplicitClose()
-
-