public class ConnectorWorkItem extends Object implements ConnectorWork
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() |
public static void initLanguageBridgeFactory(LanguageBridgeFactory factory, CommandContext context, SourceCapabilities capabilities)
public AtomicRequestID getId()
getId
in interface ConnectorWork
public void cancel(boolean abnormal)
cancel
in interface ConnectorWork
public AtomicResultsMessage more() throws TranslatorException
more
in interface ConnectorWork
TranslatorException
public void close()
close
in interface ConnectorWork
public void execute() throws TranslatorException
execute
in interface ConnectorWork
TranslatorException
protected AtomicResultsMessage handleBatch() throws TranslatorException
TranslatorException
public static AtomicResultsMessage createResultsMessage(List<?>[] batch)
public boolean isDataAvailable()
isDataAvailable
in interface ConnectorWork
public CacheDirective getCacheDirective() throws TranslatorException
getCacheDirective
in interface ConnectorWork
TranslatorException
public boolean isForkable()
isForkable
in interface ConnectorWork
public boolean isThreadBound()
isThreadBound
in interface ConnectorWork
public void logCommand(Object... command)
public void setTracingSpan(io.opentracing.Span span)
public io.opentracing.Span getTracingSpan()
Copyright © 2018 JBoss by Red Hat. All rights reserved.