Package | Description |
---|---|
com.bigdata.bop.fed | |
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
com.bigdata.relation.rule.eval |
This package supports rule evaluation.
|
com.bigdata.relation.rule.eval.pipeline |
This package implements a pipeline join.
|
com.bigdata.resources |
This package provides the logic to managed the live journal and the
historical journals and index segments for a
DataService . |
com.bigdata.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
Constructor and Description |
---|
FederatedQueryEngine(DataService dataService)
Constructor used on a
DataService (a query engine peer). |
Modifier and Type | Method and Description |
---|---|
DataService |
IResourceManager.getDataService()
The local
DataService whose resources are being managed. |
DataService |
Journal.getDataService() |
Modifier and Type | Method and Description |
---|---|
void |
ProgramTask.setDataService(DataService dataService) |
Constructor and Description |
---|
AbstractStepTask(ActionEnum action,
IJoinNexusFactory joinNexusFactory,
IStep step,
IIndexManager indexManager,
DataService dataService)
Base class handles submit either to the caller's
ExecutorService
or to the ConcurrencyManager IFF the task was submitted to a
DataService . |
MutationTask(ActionEnum action,
IJoinNexusFactory joinNexusFactory,
IStep step,
IIndexManager indexManager,
DataService dataService) |
QueryTask(IStep step,
IJoinNexusFactory joinNexusFactory,
IBlockingBuffer<ISolution[]> buffer,
IIndexManager indexManager,
DataService dataService) |
Constructor and Description |
---|
DistributedJoinTask(IRule rule,
IJoinNexus joinNexus,
int[] order,
int orderIndex,
int partitionId,
AbstractScaleOutFederation<?> fed,
IJoinMaster master,
UUID masterUUID,
IAsynchronousIterator<IBindingSet[]> src,
IKeyOrder[] keyOrders,
DataService dataService,
IVariable[][] requiredVars) |
Modifier and Type | Method and Description |
---|---|
DataService |
TestResourceManagerBootstrap.MyResourceManager.getDataService() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEmbeddedDataService
A local (in process) data service.
|
protected class |
EmbeddedFederation.EmbeddedDataServiceImpl
Concrete implementation.
|
class |
EmbeddedMetadataService
A local (in process) metadata service.
|
class |
MetadataService
Implementation of a metadata service for a named scale-out index.
|
Modifier and Type | Method and Description |
---|---|
DataService |
IDataServiceCallable.getDataService()
Return the
DataService . |
DataService |
DataServiceCallable.getDataService() |
DataService |
EmbeddedFederation.getDataService(int index)
There are
EmbeddedFederation.getDataServiceCount() data services defined in the
federation. |
DataService |
DataService.start()
Starts the
DataService . |
Modifier and Type | Method and Description |
---|---|
void |
IDataServiceCallable.setDataService(DataService dataService)
Invoked before the task is executed to provide a reference to the
IDataService on which it is executing. |
void |
DataServiceCallable.setDataService(DataService dataService)
Sets the
DataService reference and the IBigdataFederation
reference (if not already set). |
Constructor and Description |
---|
DataService.DataServiceFederationDelegate(DataService service) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.