Package | Description |
---|---|
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.
|
com.bigdata.service.ndx | |
com.bigdata.service.ndx.pipeline |
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractResourceManagerTestCase.MockMetadataService
A minimal implementation of
IMetadataService - only those methods
actually used by the ResourceManager are implemented. |
Modifier and Type | Method and Description |
---|---|
IDataService |
AbstractResourceManagerTestCase.MockFederation.getAnyDataService() |
IDataService |
AbstractResourceManagerTestCase.MockFederation.getDataService(UUID serviceUUID) |
IDataService |
AbstractResourceManagerTestCase.MockFederation.getDataServiceByName(String name) |
IDataService[] |
AbstractResourceManagerTestCase.MockFederation.getDataServices(UUID[] uuid) |
Modifier and Type | Interface and Description |
---|---|
interface |
IMetadataService
A metadata service for a named index.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEmbeddedDataService
A local (in process) data service.
|
class |
DataService
An implementation of a network-capable
IDataService . |
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 | Field and Description |
---|---|
protected IDataService |
AbstractEmbeddedFederationTestCase.dataService0 |
protected IDataService |
AbstractEmbeddedFederationTestCase.dataService1 |
Modifier and Type | Method and Description |
---|---|
IDataService |
EmbeddedFederation.getAnyDataService() |
IDataService |
IBigdataFederation.getAnyDataService()
Return ANY
IDataService which has been (or could be) discovered
and which is part of the connected federation. |
IDataService |
EmbeddedFederation.getDataService(UUID serviceUUID)
Return the (in process) data service given its service UUID.
|
IDataService |
IBigdataFederation.getDataService(UUID serviceUUID)
Resolve the service identifier to an
IDataService . |
IDataService |
EmbeddedFederation.getDataServiceByName(String name) |
IDataService |
IBigdataFederation.getDataServiceByName(String name)
Return an
IDataService joined with this
IBigdataFederation and having the specified service name. |
IDataService[] |
AbstractFederation.getDataServices(UUID[] uuids) |
IDataService[] |
IBigdataFederation.getDataServices(UUID[] uuid)
Return an array of
IDataService references that is correlated
with the given array of IDataService UUID s. |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractEmbeddedFederationTestCase.assertIndexRegistered(IDataService dataService,
String name,
UUID indexUUID)
Verify that a named index is registered on a specific
DataService
with the specified indexUUID. |
protected long |
AbstractEmbeddedFederationTestCase.awaitAsynchronousOverflow(IDataService dataService,
long priorOverflowCounter)
Waits until the asynchronous overflow counter has been incremented,
indicating that overflow processing has occurred and that post-processing
for the overflow event is complete.
|
Constructor and Description |
---|
AbstractScaleOutFederation.ForceOverflowTask(IDataService dataService,
boolean compactingMerge,
boolean truncateJournal) |
AbstractScaleOutFederation.PurgeResourcesTask(IDataService dataService,
boolean truncateJournal) |
Modifier and Type | Field and Description |
---|---|
protected IDataService |
RawDataServiceTupleIterator.dataService
The data service for the index.
|
Modifier and Type | Method and Description |
---|---|
IDataService |
AbstractScaleOutClientIndexView.getDataService(PartitionLocator pmd) |
IDataService |
ClientIndexView.getDataService(PartitionLocator pmd) |
IDataService |
IScaleOutClientIndex.getDataService(PartitionLocator pmd)
Resolve the data service to which the index partition is mapped.
|
Constructor and Description |
---|
DataServiceTupleIterator(IScaleOutClientIndex ndx,
IDataService dataService,
String name,
long timestamp,
byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter) |
RawDataServiceTupleIterator(IDataService dataService,
String name,
long timestamp,
boolean readConsistent,
byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter) |
Modifier and Type | Field and Description |
---|---|
IDataService |
IndexPartitionWriteTask.dataService
The data service on which the index partition resides.
|
Constructor and Description |
---|
IndexPartitionWriteTask(M master,
L locator,
IDataService dataService,
BlockingBuffer<E[]> buffer) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.