Package | Description |
---|---|
com.bigdata.bop |
This package provides an API for query operators.
|
com.bigdata.bop.engine | |
com.bigdata.bop.fed | |
com.bigdata.bop.fed.shards | |
com.bigdata.btree |
The
BTree is a scalable B+-Tree with copy-on-write
semantics mapping variable length unsigned byte[] keys to variable
length byte[] values (null values are allowed). |
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
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.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.
|
Modifier and Type | Method and Description |
---|---|
IBigdataFederation<?> |
BOpContextBase.getFederation()
The
IBigdataFederation IFF the operator is being evaluated on an
IBigdataFederation and otherwise null . |
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 |
---|
BOpContextBase(IBigdataFederation<?> fed,
IIndexManager localIndexManager)
Core constructor.
|
Modifier and Type | Method and Description |
---|---|
IBigdataFederation<?> |
MockRunningQuery.getFederation() |
IBigdataFederation<?> |
AbstractRunningQuery.getFederation() |
IBigdataFederation<?> |
IRunningQuery.getFederation()
The
IBigdataFederation IFF the operator is being evaluated on an
IBigdataFederation . |
IBigdataFederation<?> |
QueryEngine.getFederation()
The
IBigdataFederation iff running in scale-out. |
Constructor and Description |
---|
MockRunningQuery(IBigdataFederation<?> fed,
IIndexManager indexManager)
Note: This constructor DOES NOT check its arguments so unit tests may be
written with the minimum dependencies
|
MockRunningQuery(IBigdataFederation<?> fed,
IIndexManager indexManager,
IQueryContext queryContext) |
Modifier and Type | Method and Description |
---|---|
IBigdataFederation<?> |
FederatedQueryEngine.getFederation() |
Modifier and Type | Method and Description |
---|---|
FederatedQueryEngine |
QueryEngineFactoryBase.getFederatedQueryController(IBigdataFederation<?> fed) |
FederatedQueryEngine |
IQueryEngineFactory.getFederatedQueryController(IBigdataFederation<?> fed)
New query controller for scale-out.
|
Constructor and Description |
---|
FederatedQueryEngine(UUID thisService,
IBigdataFederation<?> fed,
IIndexManager indexManager,
ManagedResourceService resourceService)
Constructor used on a non-
DataService node to expose a query
controller. |
Constructor and Description |
---|
MapBindingSetsOverShardsBuffer(IBigdataFederation<?> fed,
IPredicate<F> pred,
long timestamp,
int capacity) |
Modifier and Type | Field and Description |
---|---|
protected IBigdataFederation<?> |
IndexSegmentStore.fed
Optional.
|
Constructor and Description |
---|
IndexSegmentStore(File file,
IBigdataFederation<?> fed)
Constructor variant that accepts an
IBigdataFederation reference
and will report out Event s. |
Modifier and Type | Method and Description |
---|---|
IBigdataFederation<?> |
IResourceManager.getFederation()
The federation whose resources are being managed.
|
IBigdataFederation<?> |
Journal.getFederation() |
Modifier and Type | Method and Description |
---|---|
BigdataSail |
BigdataSailHelper.getSail(IBigdataFederation<?> fed,
String namespace,
long timestamp)
Deprecated.
(Re-)open a SAIL backed by persistent data stored in an
IBigdataFederation . |
Modifier and Type | Method and Description |
---|---|
protected Object |
AbstractJoinNexus.runDistributedProgram(IBigdataFederation<?> fed,
ActionEnum action,
IStep step)
Runs a distributed
IProgram (key-range partitioned indices, RMI,
and multi-machine). |
Constructor and Description |
---|
JoinTaskSink(IBigdataFederation fed,
PartitionLocator locator,
JoinTask sourceJoinTask)
Setups up the local buffers for a downstream
JoinTask . |
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractResourceManagerTestCase.MockFederation
A minimal implementation of only those methods actually utilized by the
ResourceManager during the unit tests. |
Modifier and Type | Method and Description |
---|---|
IBigdataFederation |
TestResourceManagerBootstrap.MyResourceManager.getFederation() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDistributedFederation<T>
Abstract base class for
IBigdataFederation implementations where the
services are distributed using RMI and are running, at least in principle,
across more than one host/JVM. |
class |
AbstractFederation<T>
Abstract base class for
IBigdataFederation implementations. |
class |
AbstractScaleOutFederation<T>
Abstract base class for federation implementations using the scale-out index
architecture (federations that support key-range partitioned indices).
|
class |
EmbeddedFederation<T>
An implementation that uses an embedded database rather than a distributed
database.
|
Modifier and Type | Field and Description |
---|---|
protected IBigdataFederation<?> |
AbstractEmbeddedFederationTestCase.fed |
protected IBigdataFederation |
Event.fed |
Modifier and Type | Method and Description |
---|---|
IBigdataFederation<T> |
IBigdataClient.connect()
Connect to a bigdata federation.
|
IBigdataFederation<T> |
EmbeddedClient.getFederation() |
IBigdataFederation<?> |
IFederationCallable.getFederation()
Return the
IBigdataFederation reference. |
IBigdataFederation<T> |
IBigdataClient.getFederation()
Return the connected federation,
|
IBigdataFederation<?> |
FederationCallable.getFederation() |
Modifier and Type | Method and Description |
---|---|
void |
IFederationCallable.setFederation(IBigdataFederation<?> fed)
Invoked before the task is executed to provide a reference to the
IBigdataFederation for the service on which the task is
executing. |
void |
FederationCallable.setFederation(IBigdataFederation<?> fed) |
Constructor and Description |
---|
Event(IBigdataFederation fed,
EventResource resource,
Object majorEventType) |
Event(IBigdataFederation fed,
EventResource resource,
Object majorEventType,
Map<String,Object> details)
Event ctor.
|
Event(IBigdataFederation fed,
EventResource resource,
Object majorEventType,
Object minorEventType,
Map<String,Object> details)
Sub-event ctor.
|
MetadataService.DropScaleOutIndexTask(IBigdataFederation fed,
ConcurrencyManager concurrencyManager,
String name) |
MetadataService.RegisterScaleOutIndexTask(IBigdataFederation fed,
ConcurrencyManager concurrencyManager,
IResourceManager resourceManager,
String metadataIndexName,
IndexMetadata metadata,
byte[][] separatorKeys,
UUID[] dataServiceUUIDs)
Create and statically partition a scale-out index.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.