Package | Description |
---|---|
com.bigdata.bfs |
This package provides a scale-out content repository (aka distributed file
system) suitable as the backend for a REST-ful service using the bigdata
architecture.
|
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.btree.filter | |
com.bigdata.btree.view | |
com.bigdata.htree | |
com.bigdata.relation.accesspath |
This package includes an abstraction layer for efficient access paths, including
chunked iterators, blocking buffers, and an abstraction corresponding to the natural
order of an index.
|
com.bigdata.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
com.bigdata.service.ndx | |
com.bigdata.sparse |
This package provides support for treating normal B+Trees using a
"sparse row store" pattern and can be applied to both local B+Trees
and scale-out indices.
|
Constructor and Description |
---|
BlockIdentifierIterator(String id,
int version,
ITupleIterator src) |
FileVersionInputStream(String id,
int version,
ITupleIterator src) |
Modifier and Type | Interface and Description |
---|---|
interface |
ITupleCursor<E>
Interface for sequential and random-access cursor-based
ITuple
operations on an index or index partition. |
interface |
ITupleCursor2<E>
Extended interface.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBTreeTupleCursor<I extends AbstractBTree,L extends Leaf,E>
Class supporting random access to tuples and sequential tuple-based cursor
movement for an
AbstractBTree . |
static class |
AbstractBTreeTupleCursor.MutableBTreeTupleCursor<E>
|
static class |
AbstractBTreeTupleCursor.ReadOnlyBTreeTupleCursor<E>
|
class |
AbstractChunkedTupleIterator<E>
A chunked iterator that proceeds a
ResultSet at a time. |
class |
ChunkedLocalRangeIterator<E>
Chunked range iterator running against a local index or index view.
|
static class |
IndexSegment.IndexSegmentTupleCursor<E>
Implementation for an immutable
IndexSegment . |
class |
IndexSegmentMultiBlockIterator<E>
A fast iterator based on multi-block IO for the
IndexSegment . |
class |
LeafTupleIterator<E>
Visits the values of a
Leaf in the external key ordering. |
class |
ReadOnlyEntryIterator<E>
Iterator disallows
ReadOnlyEntryIterator.remove() . |
Modifier and Type | Method and Description |
---|---|
ITupleIterator |
IAbstractNode.entryIterator()
Traversal of index values in key order.
|
ITupleIterator |
Leaf.entryIterator()
Iterator visits the tuples in this leaf in key order.
|
ITupleIterator |
AbstractNode.entryIterator() |
ITupleIterator |
IRangeQuery.rangeIterator()
Visits all tuples in key order.
|
ITupleIterator |
DelegateIndex.rangeIterator() |
ITupleIterator |
ReadCommittedView.rangeIterator()
Note: The iterators returned by this view will be
read-consistent as of the lastCommitTime when they are
created.
|
ITupleIterator |
UnisolatedReadWriteIndex.rangeIterator() |
ITupleIterator |
AbstractBTree.rangeIterator() |
ITupleIterator |
IRangeQuery.rangeIterator(byte[] fromKey,
byte[] toKey)
Return an iterator that visits the entries in a half-open key range.
|
ITupleIterator |
DelegateIndex.rangeIterator(byte[] fromKey,
byte[] toKey) |
ITupleIterator |
ReadCommittedView.rangeIterator(byte[] fromKey,
byte[] toKey) |
ITupleIterator |
UnisolatedReadWriteIndex.rangeIterator(byte[] fromKey,
byte[] toKey) |
ITupleIterator |
AbstractBTree.rangeIterator(byte[] fromKey,
byte[] toKey) |
ITupleIterator |
AbstractNode.rangeIterator(byte[] fromKey,
byte[] toKey,
int flags)
Return an iterator that visits the entries in a half-open key range but
filters the values.
|
ITupleIterator |
IRangeQuery.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filterCtor)
Designated variant (the one that gets overridden) for an iterator that
visits the entries in a half-open key range.
|
ITupleIterator |
DelegateIndex.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter) |
ITupleIterator |
ReadCommittedView.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filterCtor) |
ITupleIterator |
UnisolatedReadWriteIndex.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter)
The iterator will read on the underlying index in chunks, buffering
tuples as it goes.
|
ITupleIterator |
ReadOnlyIndex.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter)
IRangeQuery.REMOVEALL and Iterator.remove() are disabled. |
ITupleIterator |
AbstractBTree.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacityIsIgnored,
int flags,
IFilter filter)
Designated variant (the one that gets overridden) for an iterator that
visits the entries in a half-open key range.
|
ITupleIterator |
AbstractBTree.rangeIterator(Object fromKey,
Object toKey)
Variant implicitly converts the optional application keys into unsigned
byte[]s.
|
ITupleIterator |
AbstractBTree.rangeIterator(Object fromKey,
Object toKey,
int capacity,
int flags,
IFilter filter)
Variant implicitly converts the optional application keys into unsigned
byte[]s.
|
Modifier and Type | Method and Description |
---|---|
static void |
AbstractBTreeTestCase.assertSameEntryIterator(ITupleIterator expectedItr,
ITupleIterator actualItr)
Verifies that the iterators visit tuples having the same data in the same
order.
|
static void |
AbstractBTreeTestCase.assertSameEntryIterator(ITupleIterator expectedItr,
ITupleIterator actualItr)
Verifies that the iterators visit tuples having the same data in the same
order.
|
static void |
AbstractBTreeTestCase.assertSameIterator(byte[][] expected,
ITupleIterator actual)
Method verifies that the actual
ITupleIterator produces the
expected values in the expected order. |
static void |
AbstractBTreeTestCase.assertSameIterator(String msg,
byte[][] expected,
ITupleIterator actual)
Method verifies that the actual
ITupleIterator produces
the expected values in the expected order. |
protected static long |
AbstractBTreeTestCase.doEntryIteratorTest(ITupleIterator<?> expectedItr,
ITupleIterator<?> actualItr)
Compares the total ordering of two B+Trees as revealed by their range
iterators
|
protected static long |
AbstractBTreeTestCase.doEntryIteratorTest(ITupleIterator<?> expectedItr,
ITupleIterator<?> actualItr)
Compares the total ordering of two B+Trees as revealed by their range
iterators
|
static IndexSegmentBuilder |
IndexSegmentBuilder.newInstance(File outFile,
File tmpDir,
long entryCount,
ITupleIterator<?> entryIterator,
int m,
IndexMetadata metadata,
long commitTime,
boolean compactingMerge,
boolean bufferNodes)
A more flexible factory for an
IndexSegment build which permits
override of the index segment branching factor, replacement of the
IndexMetadata , and the use of the caller's iterator. |
Constructor and Description |
---|
EntryScanIterator(ITupleIterator src) |
IndexSegmentBuilder(File outFile,
File tmpDir,
long entryCount,
ITupleIterator<?> entryIterator,
int m,
IndexMetadata metadata,
long commitTime,
boolean compactingMerge,
boolean bufferNodes)
Designated constructor sets up a build of an
IndexSegment for
some caller defined read-only view. |
ReadOnlyEntryIterator(ITupleIterator<E> src) |
ResultSet(IIndex ndx,
int capacity,
int flags,
ITupleIterator itr)
Constructor used to populate the
ResultSet directly from an
iterator. |
Modifier and Type | Interface and Description |
---|---|
static interface |
LookaheadTupleFilter.ILookaheadTupleIterator<E>
Extends iterator semantics for
ITuple pushback. |
Modifier and Type | Class and Description |
---|---|
class |
EmptyTupleIterator
Empty iterator.
|
class |
Reverserator<E>
Return an iterator that traverses the tuples in the reverse of the natural
index order.
|
static class |
TupleFilter.TupleFilterator<E>
Implementation class knows how to avoid side-effects from the reuse of
the same
Tuple instance by the base ITupleIterator impls. |
protected class |
TupleUpdater.Updaterator |
class |
WrappedTupleIterator<E>
Wraps an
Iterator as an ITupleIterator . |
Modifier and Type | Field and Description |
---|---|
static ITupleIterator |
EmptyTupleIterator.INSTANCE |
protected ITupleIterator<E> |
TupleFilter.TupleFilterator.src
The source iterator.
|
Modifier and Type | Method and Description |
---|---|
ITupleIterator<E> |
Advancer.filterOnce(Iterator src,
Object context) |
ITupleIterator<E> |
PrefixFilter.filterOnce(Iterator src,
Object context) |
ITupleIterator<E> |
ITupleFilter.filterOnce(Iterator src,
Object context)
Strengthened return type.
|
ITupleIterator<F> |
TupleTransformer.filterOnce(Iterator src,
Object context) |
ITupleIterator<E> |
TupleFilter.filterOnce(Iterator src,
Object context) |
ITupleIterator<E> |
TupleUpdater.filterOnce(Iterator src,
Object context) |
ITupleIterator<E> |
TupleRemover.filterOnce(Iterator src,
Object context) |
protected abstract ITupleIterator<F> |
TupleTransformer.newTransformer(LookaheadTupleFilter.ILookaheadTupleIterator<E> src,
Object context)
Method responsible for creating a new instance of the iterator that reads
from the lookahead source whose tuples are of the source type and visits
the transformed tuples.
|
Constructor and Description |
---|
TupleFilter.TupleFilterator(ITupleIterator<E> src,
Object context,
TupleFilter<E> filter) |
TupleUpdater.Updaterator(ITupleIterator<E> src,
Object context,
TupleFilter<E> filter) |
Modifier and Type | Class and Description |
---|---|
class |
FusedTupleIterator<I extends ITupleIterator<E>,E>
An aggregate iterator view of the one or more source
ITupleIterator s. |
Modifier and Type | Class and Description |
---|---|
class |
FusedTupleCursor<E>
Layers on the additional methods from the
ITupleCursor interface. |
class |
FusedTupleIterator<I extends ITupleIterator<E>,E>
An aggregate iterator view of the one or more source
ITupleIterator s. |
Modifier and Type | Field and Description |
---|---|
protected I[] |
FusedTupleIterator.sourceIterator
The source iterators in the order given to the ctor.
|
Modifier and Type | Method and Description |
---|---|
ITupleIterator |
FusedView.rangeIterator() |
ITupleIterator |
FusedView.rangeIterator(byte[] fromKey,
byte[] toKey)
Return an iterator that visits the entries in a half-open key range.
|
ITupleIterator |
FusedView.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter)
Core implementation.
|
Constructor and Description |
---|
FusedTupleIterator(int flags,
boolean deleted,
I[] sourceIterators)
Create an
ITupleIterator reading from an ordered set of source
ITupleIterator s. |
Modifier and Type | Method and Description |
---|---|
ITupleIterator |
HTree.lookupAll(byte[] key)
Return an iterator which will visit each tuple in the index having the
specified key.
|
ITupleIterator |
HTree.lookupAll(int key)
Return an iterator which will visit each tuple in the index having the
specified key.
|
ITupleIterator |
AbstractHTree.rangeIterator()
Simple iterator visits all tuples in the
HTree in order by the
effective prefix of their keys. |
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractHTreeTestCase.assertSameIterator(ITupleIterator<?> expected,
ITupleIterator<?> actual) |
protected static void |
AbstractHTreeTestCase.assertSameIterator(ITupleIterator<?> expected,
ITupleIterator<?> actual) |
Modifier and Type | Method and Description |
---|---|
protected ITupleIterator<R> |
AccessPath.rangeIterator(int capacity,
int flags,
IFilter filter) |
Modifier and Type | Method and Description |
---|---|
ITupleIterator |
CachingMetadataIndex.rangeIterator() |
ITupleIterator |
CacheOnceMetadataIndex.rangeIterator() |
ITupleIterator |
NoCacheMetadataIndexView.rangeIterator() |
ITupleIterator |
CachingMetadataIndex.rangeIterator(byte[] fromKey,
byte[] toKey) |
ITupleIterator |
CacheOnceMetadataIndex.rangeIterator(byte[] fromKey,
byte[] toKey) |
ITupleIterator |
NoCacheMetadataIndexView.rangeIterator(byte[] fromKey,
byte[] toKey) |
ITupleIterator |
CachingMetadataIndex.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter)
FIXME this is wrong.
|
ITupleIterator |
CacheOnceMetadataIndex.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter) |
ITupleIterator |
NoCacheMetadataIndexView.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter)
Note: Since this view is read-only this method forces the use of
ITx.READ_COMMITTED IFF the timestamp for the view is
ITx.UNISOLATED . |
Modifier and Type | Method and Description |
---|---|
static <E> void |
TestRangeQuery.assertSameIteratorAnyOrder(ITuple<E>[] expected,
ITupleIterator<E> actual)
Verifies that the iterator visits the specified objects in some arbitrary
ordering and that the iterator is exhausted once all expected objects
have been visited.
|
static <E> void |
TestRangeQuery.assertSameIteratorAnyOrder(String msg,
ITuple<E>[] expected,
ITupleIterator<E> actual)
Verifies that the iterator visits the specified objects in some arbitrary
ordering and that the iterator is exhausted once all expected objects
have been visited.
|
Modifier and Type | Class and Description |
---|---|
class |
DataServiceTupleIterator<E>
Class supports range query across against an unpartitioned index on an
IDataService . |
class |
PartitionedTupleIterator<E>
Class supports range query across one or more index partitions.
|
class |
RawDataServiceTupleIterator<E>
Class supports range query across against an unpartitioned index on an
IDataService but DOES NOT handle index partition splits, moves or
joins. |
Modifier and Type | Method and Description |
---|---|
ITupleIterator |
AbstractScaleOutClientIndexView.rangeIterator() |
ITupleIterator |
ClientIndexView.rangeIterator() |
ITupleIterator |
AbstractScaleOutClientIndexView.rangeIterator(byte[] fromKey,
byte[] toKey)
An
ITupleIterator that kinds the use of a series of
ResultSet s to cover all index partitions spanned by the key
range. |
ITupleIterator |
ClientIndexView.rangeIterator(byte[] fromKey,
byte[] toKey)
An
ITupleIterator that kinds the use of a series of
ResultSet s to cover all index partitions spanned by the key
range. |
ITupleIterator |
AbstractScaleOutClientIndexView.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter)
Identifies the index partition(s) that are spanned by the key range query
and maps an iterator across each index partition.
|
ITupleIterator |
ClientIndexView.rangeIterator(byte[] fromKey,
byte[] toKey,
int capacity,
int flags,
IFilter filter)
Identifies the index partition(s) that are spanned by the key range query
and maps an iterator across each index partition.
|
Modifier and Type | Method and Description |
---|---|
protected ITupleIterator<TPS> |
AtomicRowFilter.newTransformer(LookaheadTupleFilter.ILookaheadTupleIterator<TPS.TPV> src,
Object context) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.