Package | Description |
---|---|
com.bigdata.btree.proc | |
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 |
Modifier and Type | Class and Description |
---|---|
class |
SplitValuePair<K extends Split,V>
A key/value pair where the key is a Split.
|
static class |
SplitValuePair.PairComparator<K extends Split,V>
Sorts
SplitValuePair s. |
Modifier and Type | Field and Description |
---|---|
K |
SplitValuePair.key |
Modifier and Type | Method and Description |
---|---|
void |
AbstractKeyArrayIndexProcedure.ResultBitBufferHandler.aggregate(AbstractKeyArrayIndexProcedure.ResultBitBuffer result,
Split split) |
void |
AbstractKeyArrayIndexProcedure.ResultBitBufferCounter.aggregate(AbstractKeyArrayIndexProcedure.ResultBitBuffer result,
Split split) |
void |
AbstractKeyArrayIndexProcedure.ResultBufferHandler.aggregate(AbstractKeyArrayIndexProcedure.ResultBuffer result,
Split split) |
void |
BooleanORAggregator.aggregate(Boolean result,
Split split) |
void |
IntegerAggregator.aggregate(Integer result,
Split split) |
void |
LongAggregator.aggregate(Long result,
Split split) |
void |
ListResultAggregator.aggregate(R result,
Split split) |
void |
IResultHandler.aggregate(R result,
Split split)
Method is invoked for each result and is responsible for combining
the results in whatever manner is meaningful for the procedure.
|
void |
AbstractLocalSplitResultAggregator.aggregate(R result,
Split split) |
void |
IAsyncResultHandler.aggregateAsync(X[] chunk,
R result,
Split split)
Method is invoked for each result and is responsible for combining the
results in whatever manner is meaningful for the procedure.
|
Modifier and Type | Field and Description |
---|---|
Split[] |
SplitResult.splits
The array of
Split s that describes the new key range for
each new index partition created by splitting the old index
partition. |
Modifier and Type | Method and Description |
---|---|
static Split[] |
SplitUtility.getSplits(IPartitionIdFactory partitionIdFactory,
LocalPartitionMetadata oldpmd,
IndexSegment seg,
long nominalShardSize,
ISimpleSplitHandler splitHandler)
Choose a set of splits which may be reasonably expected to divide the
IndexSegment into extents each of which is approximately 50%
full. |
static Split[] |
SplitUtility.tailSplit(ResourceManager resourceManager,
BTree btree)
Identifies the splits for an index with heavy write append behavior.
|
Modifier and Type | Method and Description |
---|---|
static SplitResult |
SplitUtility.buildSplits(com.bigdata.resources.ViewMetadata vmd,
Split[] splits,
Event parentEvent)
Build N index segments based on those split points.
|
static void |
SplitUtility.validateSplits(IIndex src,
Split[] splits)
Validate splits, including: that the separator keys are strictly
ascending, that the separator keys perfectly cover the source key range
without overlap, that the rightSeparator for each split is the
leftSeparator for the prior split, that the fromIndex offsets are
strictly ascending, etc.
|
static void |
SplitUtility.validateSplits(LocalPartitionMetadata originalPartitionMetadata,
Split[] splits,
boolean checkFromToIndex)
Validate splits, including: that the separator keys are strictly
ascending, that the separator keys perfectly cover the source key range
without overlap, that the rightSeparator for each split is the
leftSeparator for the prior split, that the fromIndex offsets are
strictly ascending, etc.
|
Constructor and Description |
---|
SplitResult(String name,
IndexMetadata indexMetadata,
Split[] splits,
BuildResult[] buildResults) |
SplitUtility.BuildIndexSegmentSplitTask(com.bigdata.resources.ViewMetadata vmd,
Split split,
Event parentEvent)
Builds an
IndexSegment from the lastCommitTime of the old
journal. |
Modifier and Type | Method and Description |
---|---|
static void |
AbstractEmbeddedFederationTestCase.assertEquals(Split expected,
Split actual)
Verifies that two splits have the same data.
|
boolean |
Split.equals(Split o) |
Modifier and Type | Method and Description |
---|---|
LinkedList<Split> |
AbstractSplitter.splitKeys(long ts,
int fromIndex,
int toIndex,
byte[][] keys)
|
LinkedList<Split> |
ISplitter.splitKeys(long ts,
int fromIndex,
int toIndex,
byte[][] keys)
|
LinkedList<Split> |
AbstractScaleOutClientIndexView.splitKeys(long ts,
int fromIndex,
int toIndex,
byte[][] keys)
Utility method to split a set of ordered keys into partitions based the
index partitions defined for a scale-out index.
|
LinkedList<Split> |
ClientIndexView.splitKeys(long ts,
int fromIndex,
int toIndex,
byte[][] keys) |
LinkedList<Split> |
AbstractSplitter.splitKeys(long ts,
int fromIndex,
int toIndex,
KVO[] a)
Reshape the data into an unsigned byte[][] and then invoke
AbstractSplitter.splitKeys(long, int, int, byte[][]) . |
LinkedList<Split> |
ISplitter.splitKeys(long ts,
int fromIndex,
int toIndex,
KVO[] a)
|
LinkedList<Split> |
AbstractScaleOutClientIndexView.splitKeys(long ts,
int fromIndex,
int toIndex,
KVO[] a) |
LinkedList<Split> |
ClientIndexView.splitKeys(long ts,
int fromIndex,
int toIndex,
KVO[] a) |
Modifier and Type | Method and Description |
---|---|
void |
NopAggregator.aggregate(R result,
Split split) |
void |
IdentityHandler.aggregate(T result,
Split split) |
protected void |
TestSplitter.assertSplits(Split[] expected,
Iterator<Split> actual)
|
Modifier and Type | Method and Description |
---|---|
protected void |
TestSplitter.assertSplits(Split[] expected,
Iterator<Split> actual)
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.