Package | Description |
---|---|
com.bigdata.bop.engine | |
com.bigdata.bop.fed |
Modifier and Type | Class and Description |
---|---|
class |
ChunkedRunningQuery
IRunningQuery implementation based on the assignment of
IChunkMessage (s) to an operator task. |
Modifier and Type | Method and Description |
---|---|
AbstractRunningQuery |
QueryEngine.eval(BOp op)
Evaluate a query.
|
AbstractRunningQuery |
QueryEngine.eval(BOp op,
IBindingSet bset)
Evaluate a query.
|
AbstractRunningQuery |
QueryEngine.eval(BOp op,
IBindingSet[] bsets)
Evaluate a query.
|
AbstractRunningQuery |
QueryEngine.eval(BOp op,
IBindingSet[] bsets,
Map<Object,Object> attribs)
Evaluate a query.
|
AbstractRunningQuery |
QueryEngine.eval(UUID queryId,
BOp op,
IBindingSet bset)
Note: Used only by the test suite.
|
AbstractRunningQuery |
QueryEngine.eval(UUID queryId,
BOp op,
Map<Object,Object> queryAttributes,
IBindingSet[] bset)
Note: Used only by the test suite.
|
AbstractRunningQuery |
QueryEngine.eval(UUID queryId,
BOp op,
Map<Object,Object> queryAttributes,
IBindingSet[][] bset)
Note: Used only by the test suite.
|
AbstractRunningQuery |
QueryEngine.eval(UUID queryId,
PipelineOp query,
Map<Object,Object> queryAttributes,
IChunkMessage<IBindingSet> msg)
Evaluate a query.
|
AbstractRunningQuery |
QueryEngine.getRunningQuery(UUID queryId)
Return the
AbstractRunningQuery associated with that query
identifier. |
protected AbstractRunningQuery |
QueryEngine.newRunningQuery(UUID queryId,
boolean controller,
IQueryClient clientProxy,
UUID queryControllerId,
PipelineOp query,
IChunkMessage<IBindingSet> realSource)
Factory for
IRunningQuery s. |
protected AbstractRunningQuery |
QueryEngine.putIfAbsent(UUID queryId,
AbstractRunningQuery runningQuery)
Places the
AbstractRunningQuery object into the internal map. |
Modifier and Type | Method and Description |
---|---|
protected void |
QueryEngine.halt(AbstractRunningQuery q)
The query is no longer running.
|
protected AbstractRunningQuery |
QueryEngine.putIfAbsent(UUID queryId,
AbstractRunningQuery runningQuery)
Places the
AbstractRunningQuery object into the internal map. |
Modifier and Type | Class and Description |
---|---|
class |
FederatedRunningQuery
Extends
ChunkedRunningQuery to provide additional state and logic
required to support distributed query evaluation against an
IBigdataFederation . |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.