Package org.teiid.dqp.internal.datamgr
Class ConnectorWorkItem
- java.lang.Object
-
- org.teiid.dqp.internal.datamgr.ConnectorWorkItem
-
- All Implemented Interfaces:
ConnectorWork
public class ConnectorWorkItem extends Object implements ConnectorWork
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel(boolean abnormal)
void
close()
static AtomicResultsMessage
createResultsMessage(List<?>[] batch)
boolean
equals(Object obj)
void
execute()
CacheDirective
getCacheDirective()
AtomicRequestID
getId()
io.opentracing.Span
getTracingSpan()
protected AtomicResultsMessage
handleBatch()
int
hashCode()
static void
initLanguageBridgeFactory(LanguageBridgeFactory factory, CommandContext context, SourceCapabilities capabilities)
boolean
isDataAvailable()
boolean
isForkable()
boolean
isThreadBound()
void
logCommand(Object... command)
AtomicResultsMessage
more()
void
setTracingSpan(io.opentracing.Span span)
String
toString()
-
-
-
Method Detail
-
initLanguageBridgeFactory
public static void initLanguageBridgeFactory(LanguageBridgeFactory factory, CommandContext context, SourceCapabilities capabilities)
-
getId
public AtomicRequestID getId()
- Specified by:
getId
in interfaceConnectorWork
-
cancel
public void cancel(boolean abnormal)
- Specified by:
cancel
in interfaceConnectorWork
-
more
public AtomicResultsMessage more() throws TranslatorException
- Specified by:
more
in interfaceConnectorWork
- Throws:
TranslatorException
-
close
public void close()
- Specified by:
close
in interfaceConnectorWork
-
execute
public void execute() throws TranslatorException
- Specified by:
execute
in interfaceConnectorWork
- Throws:
TranslatorException
-
handleBatch
protected AtomicResultsMessage handleBatch() throws TranslatorException
- Throws:
TranslatorException
-
createResultsMessage
public static AtomicResultsMessage createResultsMessage(List<?>[] batch)
-
isDataAvailable
public boolean isDataAvailable()
- Specified by:
isDataAvailable
in interfaceConnectorWork
-
getCacheDirective
public CacheDirective getCacheDirective() throws TranslatorException
- Specified by:
getCacheDirective
in interfaceConnectorWork
- Throws:
TranslatorException
-
isForkable
public boolean isForkable()
- Specified by:
isForkable
in interfaceConnectorWork
-
isThreadBound
public boolean isThreadBound()
- Specified by:
isThreadBound
in interfaceConnectorWork
-
logCommand
public void logCommand(Object... command)
-
setTracingSpan
public void setTracingSpan(io.opentracing.Span span)
-
getTracingSpan
public io.opentracing.Span getTracingSpan()
-
-