| 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  DataServicewhose 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  ExecutorServiceor to theConcurrencyManagerIFF the task was submitted to aDataService. | 
| 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  | AbstractEmbeddedDataServiceA local (in process) data service. | 
| protected class  | EmbeddedFederation.EmbeddedDataServiceImplConcrete implementation. | 
| class  | EmbeddedMetadataServiceA local (in process) metadata service. | 
| class  | MetadataServiceImplementation 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
  IDataServiceon which it is executing. | 
| void | DataServiceCallable. setDataService(DataService dataService)Sets the  DataServicereference and theIBigdataFederationreference (if not already set). | 
| Constructor and Description | 
|---|
| DataService.DataServiceFederationDelegate(DataService service) | 
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.