Package | Description |
---|---|
com.bigdata.bop |
This package provides an API for query operators.
|
com.bigdata.bop.engine | |
com.bigdata.bop.fed | |
com.bigdata.bop.joinGraph.rto | |
com.bigdata.rdf.sail |
This package contains the SAIL that allow bigdata to be used as a backend for
the Sesame 2.x platform.
|
com.bigdata.rdf.sparql.ast.eval.rto |
Modifier and Type | Method and Description |
---|---|
IRunningQuery |
BOpContext.getRunningQuery()
The interface for a running query.
|
IRunningQuery |
BOpContext.getRunningQuery(UUID queryId)
Return the
IRunningQuery associated with the specified queryId. |
Modifier and Type | Method and Description |
---|---|
static <E> BOpContext<E> |
BOpContext.newMock(IRunningQuery runningQuery,
IBigdataFederation<?> fed,
IIndexManager localIndexManager,
int partitionId,
BOpStats stats,
PipelineOp op,
boolean lastInvocation,
ICloseableIterator<E[]> source,
IBlockingBuffer<E[]> sink,
IBlockingBuffer<E[]> sink2)
Test suite helper.
|
Constructor and Description |
---|
BOpContext(IRunningQuery runningQuery,
int partitionId,
BOpStats stats,
PipelineOp op,
boolean lastInvocation,
ICloseableIterator<E[]> source,
IBlockingBuffer<E[]> sink,
IBlockingBuffer<E[]> sink2) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRunningQuery
Abstract base class for various
IRunningQuery implementations. |
class |
ChunkedRunningQuery
IRunningQuery implementation based on the assignment of
IChunkMessage (s) to an operator task. |
class |
MockRunningQuery
Mock object.
|
Modifier and Type | Method and Description |
---|---|
IRunningQuery[] |
AbstractRunningQuery.getChildren()
Report a snapshot of the known (declared) child
IRunningQuery s
for this IRunningQuery and (recursively) for any children of this
IRunningQuery . |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractRunningQuery.addChild(IRunningQuery childQuery)
Attach a child query.
|
static void |
AbstractQueryEngineTestCase.assertSameSolutions(IBindingSet[] expected,
IRunningQuery runningQuery)
Verify the expected solutions.
|
static void |
AbstractQueryEngineTestCase.assertSameSolutionsAnyOrder(IBindingSet[] expected,
IRunningQuery runningQuery)
Verifies that the iterator visits the specified objects in some arbitrary
ordering and that the iterator is exhausted once all expected objects
have been visited.
|
static void |
AbstractQueryEngineTestCase.assertSameSolutionsAnyOrder(String msg,
IBindingSet[] expected,
IRunningQuery runningQuery)
Verifies that the iterator visits the specified objects in some arbitrary
ordering and that the iterator is exhausted once all expected objects
have been visited.
|
static void |
QueryLog.getTableRowsXHTML(String queryStr,
IRunningQuery q,
Writer w,
Map<Integer,QueueStats> queueStats,
int maxBopLength,
boolean clusterStats,
boolean detailedStats,
boolean mutationStats)
Write the table rows.
|
static void |
QueryLog.getTableXHTML(String queryStr,
IRunningQuery q,
IRunningQuery[] children,
Writer w,
boolean summaryOnly,
int maxBopLength,
boolean clusterStats,
boolean detailedStats,
boolean mutationStats)
Format the data as an (X)HTML table.
|
static void |
QueryLog.getTableXHTML(String queryStr,
IRunningQuery q,
IRunningQuery[] children,
Writer w,
boolean summaryOnly,
int maxBopLength,
boolean clusterStats,
boolean detailedStats,
boolean mutationStats)
Format the data as an (X)HTML table.
|
int |
IChunkHandler.handleChunk(IRunningQuery query,
int bopId,
int sinkId,
IBindingSet[] chunk)
Take an
IBindingSet [] chunk generated by some pass over an
operator and make it available to the target operator. |
int |
StandaloneChunkHandler.handleChunk(IRunningQuery query,
int bopId,
int sinkId,
IBindingSet[] chunk) |
static void |
QueryLog.log(IRunningQuery q)
Log rule execution statistics @ INFO.
|
void |
QueryEngine.IRunningQueryListener.notify(IRunningQuery q) |
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 . |
Modifier and Type | Method and Description |
---|---|
int |
FederationChunkHandler.handleChunk(IRunningQuery query,
int bopId,
int sinkId,
IBindingSet[] chunk)
Take an
IBindingSet [] chunk generated by some pass over an
operator and make it available to the target operator. |
Modifier and Type | Method and Description |
---|---|
Path |
JoinGraph.getPath(IRunningQuery q)
Return the computed join path.
|
PipelineOp |
JoinGraph.getQueryPlan(IRunningQuery q)
Return the query plan to be executed based on the RTO determined join
ordering.
|
Map<PathIds,EdgeSample> |
JoinGraph.getSamples(IRunningQuery q)
Return the samples associated with the computed join path.
|
Constructor and Description |
---|
RunningQueryCloseableIterator(IRunningQuery runningQuery,
ICloseableIterator<E> src) |
Modifier and Type | Method and Description |
---|---|
Set<IRunningQuery> |
AbstractRTOTestCase.MyQueryListener.getRunningQueries()
Return each
IRunningQuery that was noticed by this listener. |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRTOTestCase.MyQueryListener.notify(IRunningQuery q) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.