Uses of Class
com.bigdata.mdi.PartitionLocator

Packages that use PartitionLocator

Package	Description
com.bigdata.bop.fed.shards
com.bigdata.mdi	This package provides a metadata index and range partitioned indices managed by that metadata index.
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.
com.bigdata.service.ndx
com.bigdata.service.ndx.pipeline

Uses of PartitionLocator in com.bigdata.bop.fed.shards

Methods in com.bigdata.bop.fed.shards that return types with arguments of type PartitionLocator

Modifier and Type	Method and Description
Map<PartitionLocator,IBuffer<IBindingSet[]>>	MapBindingSetsOverShardsBuffer.getSinks() An immutable view of the sinks.
protected Iterator<PartitionLocator>	MapBindingSetsOverShardsBuffer.locatorScan(IKeyOrder<F> keyOrder, byte[] fromKey, byte[] toKey) Locator scan for the index partitions for that predicate as bound.

Methods in com.bigdata.bop.fed.shards with parameters of type PartitionLocator

Modifier and Type	Method and Description
protected IBuffer<IBindingSet[]>	MapBindingSetsOverShardsBuffer.getBuffer(PartitionLocator locator) Return the buffer used to absorb binding sets which target the specified index partition.
protected abstract IBuffer<IBindingSet[]>	MapBindingSetsOverShardsBuffer.newBuffer(PartitionLocator locator) Return a buffer onto which binding sets will be written which are destined for the specified shard.

Uses of PartitionLocator in com.bigdata.mdi

Methods in com.bigdata.mdi that return PartitionLocator

Modifier and Type	Method and Description
PartitionLocator	IMetadataIndex.find(byte[] key) Find and return the partition spanning the given key.
PartitionLocator	MetadataIndex.find(byte[] key)
PartitionLocator	MetadataIndexView.find(byte[] key) The method is used to discover the locator for the index partition within which the key would be found.
PartitionLocator	IMetadataIndex.get(byte[] key) The partition with that separator key or null (exact match on the separator key).
PartitionLocator	MetadataIndex.get(byte[] key)
PartitionLocator	MetadataIndexView.get(byte[] key)

Methods in com.bigdata.mdi with parameters of type PartitionLocator

Modifier and Type	Method and Description
void	IMetadataIndex.staleLocator(PartitionLocator locator) Notification that a locator is stale.
void	MetadataIndex.staleLocator(PartitionLocator locator) Passes the notice along to the MetadataIndex.view.
void	MetadataIndexView.staleLocator(PartitionLocator locator) Remove the locator from the MetadataIndexView.locatorCache.

Uses of PartitionLocator in com.bigdata.relation.rule.eval

Methods in com.bigdata.relation.rule.eval that return types with arguments of type PartitionLocator

Modifier and Type	Method and Description
Iterator<PartitionLocator>	AbstractJoinNexus.locatorScan(AbstractScaleOutFederation<?> fed, IPredicate<?> predicate)
Iterator<PartitionLocator>	IJoinNexus.locatorScan(AbstractScaleOutFederation<?> fed, IPredicate<?> predicate) Return an iterator visiting the PartitionLocator for the index partitions from which an IAccessPath must read in order to materialize all elements which would be visited for that predicate.

Uses of PartitionLocator in com.bigdata.relation.rule.eval.pipeline

Methods in com.bigdata.relation.rule.eval.pipeline with parameters of type PartitionLocator

Modifier and Type	Method and Description
protected JoinTaskSink	DistributedJoinTask.getSink(PartitionLocator locator) Return the sink on which we will write IBindingSet for the index partition associated with the specified locator.

Constructors in com.bigdata.relation.rule.eval.pipeline with parameters of type PartitionLocator

Constructor and Description
JoinTaskSink(IBigdataFederation fed, PartitionLocator locator, JoinTask sourceJoinTask) Setups up the local buffers for a downstream JoinTask.

Uses of PartitionLocator in com.bigdata.resources

Fields in com.bigdata.resources declared as PartitionLocator

Modifier and Type	Field and Description
PartitionLocator	MoveResult.newLocator
PartitionLocator	MoveResult.oldLocator

Methods in com.bigdata.resources that return PartitionLocator

Modifier and Type	Method and Description
PartitionLocator	AbstractResourceManagerTestCase.MockMetadataService.find(String name, long timestamp, byte[] key)
PartitionLocator	AbstractResourceManagerTestCase.MockMetadataService.get(String name, long timestamp, byte[] key)

Methods in com.bigdata.resources with parameters of type PartitionLocator

Modifier and Type	Method and Description
void	AbstractResourceManagerTestCase.MockMetadataService.joinIndexPartition(String name, PartitionLocator[] oldLocators, PartitionLocator newLocator)
void	AbstractResourceManagerTestCase.MockMetadataService.joinIndexPartition(String name, PartitionLocator[] oldLocators, PartitionLocator newLocator)
void	AbstractResourceManagerTestCase.MockMetadataService.moveIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator newLocator)
void	AbstractResourceManagerTestCase.MockMetadataService.splitIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator[] newLocators)
void	AbstractResourceManagerTestCase.MockMetadataService.splitIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator[] newLocators)

Constructors in com.bigdata.resources with parameters of type PartitionLocator

Constructor and Description
MoveResult(String name, IndexMetadata indexMetadata, UUID targetDataServiceUUID, int newPartitionId, PartitionLocator oldLocator, PartitionLocator newLocator)

Uses of PartitionLocator in com.bigdata.service

Fields in com.bigdata.service declared as PartitionLocator

Modifier and Type	Field and Description
protected PartitionLocator	MetadataService.JoinIndexPartitionTask.newLocator
protected PartitionLocator	MetadataService.MoveIndexPartitionTask.newLocator
protected PartitionLocator[]	MetadataService.SplitIndexPartitionTask.newLocators
protected PartitionLocator	MetadataService.SplitIndexPartitionTask.oldLocator
protected PartitionLocator	MetadataService.MoveIndexPartitionTask.oldLocator
protected PartitionLocator[]	MetadataService.JoinIndexPartitionTask.oldLocators

Methods in com.bigdata.service that return PartitionLocator

Modifier and Type	Method and Description
PartitionLocator	CachingMetadataIndex.find(byte[] key)
PartitionLocator	CacheOnceMetadataIndex.find(byte[] key)
PartitionLocator	NoCacheMetadataIndexView.find(byte[] key)
PartitionLocator	IMetadataService.find(String name, long timestamp, byte[] key) Find and return the partition spanning the given key.
PartitionLocator	MetadataService.find(String name, long timestamp, byte[] key)
PartitionLocator	CachingMetadataIndex.get(byte[] key)
PartitionLocator	CacheOnceMetadataIndex.get(byte[] key)
PartitionLocator	NoCacheMetadataIndexView.get(byte[] key)
PartitionLocator	IMetadataService.get(String name, long timestamp, byte[] key) The partition with that separator key or null (exact match on the separator key).
PartitionLocator	MetadataService.get(String name, long timestamp, byte[] key)

Methods in com.bigdata.service that return types with arguments of type PartitionLocator

Modifier and Type	Method and Description
Iterator<PartitionLocator>	AbstractScaleOutFederation.locatorScan(String name, long timestamp, byte[] fromKey, byte[] toKey, boolean reverseScan) Returns an iterator that will visit the PartitionLocators for the specified scale-out index key range.

Methods in com.bigdata.service with parameters of type PartitionLocator

Modifier and Type	Method and Description
void	IMetadataService.joinIndexPartition(String name, PartitionLocator[] oldLocators, PartitionLocator newLocator) Updates the MetadataIndex for the named scale-out index to reflect the join of N index partitions (which must be siblings) into a single index partition.
void	IMetadataService.joinIndexPartition(String name, PartitionLocator[] oldLocators, PartitionLocator newLocator) Updates the MetadataIndex for the named scale-out index to reflect the join of N index partitions (which must be siblings) into a single index partition.
void	MetadataService.joinIndexPartition(String name, PartitionLocator[] oldLocators, PartitionLocator newLocator)
void	MetadataService.joinIndexPartition(String name, PartitionLocator[] oldLocators, PartitionLocator newLocator)
void	IMetadataService.moveIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator newLocator) Updates the MetadataIndex for the named scale-out index to reflect the move of an index partition from one data service to another.
void	MetadataService.moveIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator newLocator)
void	IMetadataService.splitIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator[] newLocators) Updates the MetadataIndex for the named scale-out index to reflect the split of an index partition into N new index partitions.
void	IMetadataService.splitIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator[] newLocators) Updates the MetadataIndex for the named scale-out index to reflect the split of an index partition into N new index partitions.
void	MetadataService.splitIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator[] newLocators)
void	MetadataService.splitIndexPartition(String name, PartitionLocator oldLocator, PartitionLocator[] newLocators)
void	CachingMetadataIndex.staleLocator(PartitionLocator locator) Re-fetches the locator(s).
void	CacheOnceMetadataIndex.staleLocator(PartitionLocator locator)
void	NoCacheMetadataIndexView.staleLocator(PartitionLocator locator) NOP since nothing is cached.

Constructors in com.bigdata.service with parameters of type PartitionLocator

Constructor and Description
MetadataService.JoinIndexPartitionTask(IConcurrencyManager concurrencyManager, String resource, PartitionLocator[] oldLocators, PartitionLocator newLocator)
MetadataService.JoinIndexPartitionTask(IConcurrencyManager concurrencyManager, String resource, PartitionLocator[] oldLocators, PartitionLocator newLocator)
MetadataService.MoveIndexPartitionTask(IConcurrencyManager concurrencyManager, String resource, PartitionLocator oldLocator, PartitionLocator newLocator)
MetadataService.SplitIndexPartitionTask(IConcurrencyManager concurrencyManager, String resource, PartitionLocator oldLocator, PartitionLocator[] newLocators)
MetadataService.SplitIndexPartitionTask(IConcurrencyManager concurrencyManager, String resource, PartitionLocator oldLocator, PartitionLocator[] newLocators)

Uses of PartitionLocator in com.bigdata.service.ndx

Methods in com.bigdata.service.ndx that return types with arguments of type PartitionLocator

Modifier and Type	Method and Description
Iterator<PartitionLocator>	AbstractScaleOutClientIndexView.locatorScan(long ts, byte[] fromKey, byte[] toKey, boolean reverseScan)
Iterator<PartitionLocator>	ClientIndexView.locatorScan(long ts, byte[] fromKey, byte[] toKey, boolean reverseScan)
Iterator<PartitionLocator>	IScaleOutClientIndex.locatorScan(long ts, byte[] fromKey, byte[] toKey, boolean reverseScan) Returns an iterator that will visit the PartitionLocators for the specified scale-out index key range.

Methods in com.bigdata.service.ndx with parameters of type PartitionLocator

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.
void	AbstractScaleOutClientIndexView.staleLocator(long ts, PartitionLocator locator, StaleLocatorException cause)
void	ClientIndexView.staleLocator(long ts, PartitionLocator locator, StaleLocatorException cause)
void	IScaleOutClientIndex.staleLocator(long ts, PartitionLocator locator, StaleLocatorException cause) Notifies the client that a StaleLocatorException was received.

Uses of PartitionLocator in com.bigdata.service.ndx.pipeline

Classes in com.bigdata.service.ndx.pipeline with type parameters of type PartitionLocator

Modifier and Type	Class and Description
class	IndexPartitionWriteTask<H extends IndexAsyncWriteStats<L,HS>,O,E extends KVO<O>,L extends PartitionLocator,S extends IndexPartitionWriteTask,HS extends IndexPartitionWriteStats,M extends IndexWriteTask<H,O,E,S,L,HS,T,R,A>,T extends IKeyArrayIndexProcedure,R,A> Class drains a BlockingBuffer writing on a specific index partition.
class	IndexWriteTask<H extends IndexAsyncWriteStats<L,HS>,O,E extends KVO<O>,S extends IndexPartitionWriteTask,L extends PartitionLocator,HS extends IndexPartitionWriteStats,T extends IKeyArrayIndexProcedure,R,A> Task drains a BlockingBuffer containing KVO[] chunks, splits the chunks based on the separator keys for the scale-out index, and then assigns each chunk to per-index partition BlockingBuffer which is in turned drained by an IndexPartitionWriteTask that writes onto a specific index partition.

Constructor parameters in com.bigdata.service.ndx.pipeline with type arguments of type PartitionLocator

Constructor and Description
IndexWriteTask.M(IScaleOutClientIndex ndx, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos, int sinkQueueCapacity, int sinkChunkSize, long sinkChunkTimeoutNanos, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor, IResultHandler<R,A> resultHandler, IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats> stats, BlockingBuffer<KVO<O>[]> buffer)