public class ParallelGetStatementsTask extends ParallelTaskBase<Statement>
StatementPattern using the provided triple source.| Modifier and Type | Field and Description |
|---|---|
protected Resource[] |
contexts |
protected Endpoint |
endpoint |
protected Value |
obj |
protected IRI |
pred |
protected QueryInfo |
queryInfo |
protected Resource |
subj |
protected ParallelExecutor<Statement> |
unionControl |
scheduledFuture| Constructor and Description |
|---|
ParallelGetStatementsTask(ParallelExecutor<Statement> unionControl,
Endpoint endpoint,
Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts) |
| Modifier and Type | Method and Description |
|---|---|
ParallelExecutor<Statement> |
getControl()
return the controlling instance, e.g.
|
protected CloseableIteration<Statement,QueryEvaluationException> |
performTaskInternal() |
cancel, performTask, setScheduledFuture, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetQueryInfoprotected final ParallelExecutor<Statement> unionControl
protected final Endpoint endpoint
protected final Resource subj
protected final IRI pred
protected final Value obj
protected final QueryInfo queryInfo
protected Resource[] contexts
public ParallelExecutor<Statement> getControl()
ParallelTaskprotected CloseableIteration<Statement,QueryEvaluationException> performTaskInternal() throws Exception
performTaskInternal in class ParallelTaskBase<Statement>ExceptionCopyright © 2015-2022 Eclipse Foundation. All Rights Reserved.