Package | Description |
---|---|
com.bigdata.bop.engine | |
com.bigdata.bop.fed |
Modifier and Type | Method and Description |
---|---|
void |
LocalNativeChunkMessage.materialize(FederatedRunningQuery runningQuery) |
void |
LocalChunkMessage.materialize(FederatedRunningQuery runningQuery) |
void |
IChunkMessage.materialize(FederatedRunningQuery runningQuery)
Materialize the chunk on the receiver.
|
Modifier and Type | Method and Description |
---|---|
FederatedRunningQuery |
FederatedQueryEngine.getRunningQuery(UUID queryId)
Overridden to strengthen the return type.
|
protected FederatedRunningQuery |
FederatedQueryEngine.newRunningQuery(UUID queryId,
boolean controller,
IQueryClient clientProxy,
UUID queryControllerId,
PipelineOp query,
IChunkMessage<IBindingSet> realSource)
Factory for
IRunningQuery s. |
Modifier and Type | Method and Description |
---|---|
void |
ThickChunkMessage.materialize(FederatedRunningQuery runningQuery) |
void |
NIOChunkMessage.materialize(FederatedRunningQuery runningQuery) |
void |
EmptyChunkMessage.materialize(FederatedRunningQuery runningQuery) |
protected void |
FederationChunkHandler.sendChunkMessage(FederatedRunningQuery q,
UUID serviceUUID,
int sinkId,
int partitionId,
DirectBufferPoolAllocator.IAllocationContext allocationContext,
IBindingSet[] source)
Create and send an
IChunkMessage from some intermediate results. |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.