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

Modifier and Type	Method and 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()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

initLanguageBridgeFactory

public static void initLanguageBridgeFactory(LanguageBridgeFactory factory,
                                             CommandContext context,
                                             SourceCapabilities capabilities)

getId

public AtomicRequestID getId()

Specified by:

getId in interface ConnectorWork

cancel

public void cancel(boolean abnormal)

Specified by:

cancel in interface ConnectorWork

more

public AtomicResultsMessage more()
                          throws TranslatorException

Specified by:

more in interface ConnectorWork

Throws:

TranslatorException

close

public void close()

Specified by:

close in interface ConnectorWork

execute

public void execute()
             throws TranslatorException

Specified by:

execute in interface ConnectorWork

Throws:

TranslatorException

handleBatch

protected AtomicResultsMessage handleBatch()
                                    throws TranslatorException

Throws:

TranslatorException

createResultsMessage

public static AtomicResultsMessage createResultsMessage(List<?>[] batch)

toString

public String toString()

Overrides:

toString in class Object

isDataAvailable

public boolean isDataAvailable()

Specified by:

isDataAvailable in interface ConnectorWork

getCacheDirective

public CacheDirective getCacheDirective()
                                 throws TranslatorException

Specified by:

getCacheDirective in interface ConnectorWork

Throws:

TranslatorException

isForkable

public boolean isForkable()

Specified by:

isForkable in interface ConnectorWork

isThreadBound

public boolean isThreadBound()

Specified by:

isThreadBound in interface ConnectorWork

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

logCommand

public void logCommand(Object... command)

setTracingSpan

public void setTracingSpan(io.opentracing.Span span)

getTracingSpan

public io.opentracing.Span getTracingSpan()