Uses of Class
com.bigdata.mdi.PartitionLocator

Packages that use PartitionLocator

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.jini.util
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

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

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

PartitionLocator	MetadataIndex.find(byte[] key)
PartitionLocator	IMetadataIndex.find(byte[] key) Find and return the partition spanning the given 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	MetadataIndex.get(byte[] key)
PartitionLocator	IMetadataIndex.get(byte[] key) The partition with that separator key or null (exact match on the separator key).
PartitionLocator	MetadataIndexView.get(byte[] key)

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

void	MetadataIndex.staleLocator(PartitionLocator locator) Passes the notice along to the MetadataIndex.view.
void	IMetadataIndex.staleLocator(PartitionLocator locator) Notification that a locator is stale.
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

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.
Iterator<PartitionLocator>	AbstractJoinNexus.locatorScan(AbstractScaleOutFederation<?> fed, IPredicate<?> predicate)

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

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

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

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

PartitionLocator	MoveResult.newLocator
PartitionLocator	MoveResult.oldLocator

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

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

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

PartitionLocator	CacheOnceMetadataIndex.find(byte[] key)
PartitionLocator	CachingMetadataIndex.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	CacheOnceMetadataIndex.get(byte[] key)
PartitionLocator	CachingMetadataIndex.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

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

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	CacheOnceMetadataIndex.staleLocator(PartitionLocator locator)
void	CachingMetadataIndex.staleLocator(PartitionLocator locator) Re-fetches the locator(s).
void	NoCacheMetadataIndexView.staleLocator(PartitionLocator locator) NOP since nothing is cached.

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

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.jini.util

Fields in com.bigdata.service.jini.util declared as PartitionLocator

PartitionLocator

DumpFederation.IndexPartitionRecord.locator The index partition locator (from the ctor).

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

DumpFederation.IndexPartitionRecord(JiniFederation<?> fed, long ts, String indexName, PartitionLocator locator)

Uses of PartitionLocator in com.bigdata.service.ndx

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

Iterator<PartitionLocator>	ClientIndexView.locatorScan(long ts, byte[] fromKey, byte[] toKey, boolean reverseScan)
Iterator<PartitionLocator>	AbstractScaleOutClientIndexView.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

IDataService	ClientIndexView.getDataService(PartitionLocator pmd)
IDataService	AbstractScaleOutClientIndexView.getDataService(PartitionLocator pmd)
IDataService	IScaleOutClientIndex.getDataService(PartitionLocator pmd) Resolve the data service to which the index partition is mapped.
void	ClientIndexView.staleLocator(long ts, PartitionLocator locator, StaleLocatorException cause)
void	AbstractScaleOutClientIndexView.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

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

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)