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.bop.ap.filter |
These filters are based on the striterator patterns.
|
com.bigdata.bop.join | |
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.isolation | |
com.bigdata.btree.view | |
com.bigdata.counters.store |
This package provides a persistence mechanism for performance
counters.
|
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
com.bigdata.rdf.lexicon | |
com.bigdata.rdf.sparql.ast.eval | |
com.bigdata.rdf.sparql.ast.service.history | |
com.bigdata.rdf.spo |
This package defines a statement model using long term identifiers rather than
RDF Value objects.
|
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.resources |
This package provides the logic to managed the live journal and the
historical journals and index segments for a
DataService . |
com.bigdata.search |
This package provides full text indexing and search.
|
com.bigdata.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
com.bigdata.service.geospatial | |
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.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
BlobOverflowHandler.handle(ITuple tuple,
IRawStore target) |
protected boolean |
FileVersionDeleter.isValid(ITuple<TPS.TPV> tuple)
Only visits the
FileMetadataSchema.VERSION columns. |
protected void |
FileVersionDeleter.update(IIndex ndx,
ITuple<TPS.TPV> tuple)
Appends a new tuple into the index whose key uses the
FileVersionDeleter.choosenTimestamp and whose value is an encoded null . |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
BOpTupleFilter.isValid(ITuple<E> obj)
Return
true iff the object should be accepted. |
Modifier and Type | Method and Description |
---|---|
protected IBindingSet |
HTreeHashJoinUtility.decodeSolution(ITuple<?> t)
Decode a solution from an encoded
IV []. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractChunkedTupleIterator.ResultSetTuple
|
class |
AbstractTuple<E>
Abstract base class with much of the functionality of
ITuple . |
class |
DelegateTuple<E>
An
ITuple wrapping a delegate that may be used to override some of
the methods on the delegate object. |
class |
TestTuple<E>
Test helper for a tuple with static data.
|
class |
Tuple<E>
A key-value pair used to facilitate some iterator constructs.
|
Modifier and Type | Field and Description |
---|---|
protected ITuple<E> |
DelegateTuple.delegate |
Modifier and Type | Method and Description |
---|---|
ITuple<E> |
AbstractBTreeTupleCursor.first() |
ITuple<E> |
ITupleCursor2.first()
Position the cursor on the first visitable tuple in the natural index
order for the index or index partition over which the cursor is defined.
|
ITuple<E> |
AbstractBTreeTupleCursor.last() |
ITuple<E> |
ITupleCursor2.last()
Position the cursor on the last visitable tuple in the natural index
order for the index or index partition over which the cursor is defined.
|
ITuple<E> |
ReadOnlyEntryIterator.next() |
ITuple<E> |
AbstractBTreeTupleCursor.next() |
ITuple<E> |
ChunkedLocalRangeIterator.next()
Visits the next tuple, queuing it for removal unless
IRangeQuery.CURSOR was specified, in which case it is deleted
immediately. |
ITuple<E> |
ITupleCursor.next()
Position the cursor on the next tuple in the natural key order of the
index.
|
ITuple<E> |
ITupleIterator.next()
Advance the iterator and return the
ITuple from which you can
extract the data and metadata for next entry. |
ITuple<E> |
LeafTupleIterator.next() |
ITuple<E> |
IndexSegmentMultiBlockIterator.next() |
ITuple<E> |
AbstractChunkedTupleIterator.next() |
ITuple<E> |
AbstractBTreeTupleCursor.nextTuple()
Position the cursor on the first visitable tuple ordered greater than the
current cursor position in the natural key order of the index and return
that tuple.
|
ITuple<E> |
ITupleCursor2.nextTuple()
Position the cursor on the first visitable tuple ordered greater than the
current cursor position in the natural key order of the index and return
that tuple.
|
ITuple<E> |
AbstractBTreeTupleCursor.prior() |
ITuple<E> |
ITupleCursor.prior()
Position the cursor on the first visitable tuple ordered less than the
current cursor position in the natural key order of the index and return
that tuple.
|
ITuple<E> |
AbstractBTreeTupleCursor.priorTuple()
Position the cursor on the first visitable tuple ordered less than the
current cursor position in the natural key order of the index and return
that tuple.
|
ITuple<E> |
ITupleCursor2.priorTuple()
Position the cursor on the first visitable tuple ordered less than the
current cursor position in the natural key order of the index and return
that tuple.
|
ITuple<E> |
AbstractBTreeTupleCursor.seek(byte[] key) |
ITuple<E> |
ITupleCursor.seek(byte[] key)
Positions the cursor on the specified key.
|
ITuple<E> |
AbstractBTreeTupleCursor.seek(Object key) |
ITuple<E> |
ITupleCursor.seek(Object key)
Variant that first encodes the key using the object returned by
IndexMetadata.getTupleSerializer() for the backing index. |
ITuple<E> |
AbstractBTreeTupleCursor.tuple() |
ITuple<E> |
ITupleCursor2.tuple()
The tuple reflecting the data in the index at the current cursor
position.
|
Modifier and Type | Method and Description |
---|---|
static void |
AbstractTupleCursorTestCase.assertEquals(ITuple expected,
ITuple actual)
Compares two tuples for equality based on their data (flags, keys,
values, deleted marker, and version timestamp).
|
static void |
AbstractTupleCursorTestCase.assertEquals(ITuple expected,
ITuple actual)
Compares two tuples for equality based on their data (flags, keys,
values, deleted marker, and version timestamp).
|
void |
AbstractTuple.copyTuple(ITuple t)
Sets all fields and increments the tuple visited counter.
|
protected void |
ResultSet.copyTuple(ITuple<?> tuple)
Copies the data from the tuple into the internal buffers.
|
V |
DefaultTupleSerializer.deserialize(ITuple tuple)
De-serializes an object from the
value stored
in the tuple (ignores the key stored in the tuple). |
Object |
NOPTupleSerializer.deserialize(ITuple tuple) |
V |
ITupleSerializer.deserialize(ITuple tuple)
De-serialize an object from an
ITuple . |
K |
DefaultTupleSerializer.deserializeKey(ITuple tuple)
This is an unsupported operation.
|
Object |
NOPTupleSerializer.deserializeKey(ITuple tuple)
This is an unsupported operation.
|
K |
ITupleSerializer.deserializeKey(ITuple tuple)
De-serialize the application key from an
ITuple (optional
operation). |
byte[] |
IOverflowHandler.handle(ITuple tuple,
IRawStore target)
Invoked for each index entry.
|
static String |
AbstractTuple.toString(ITuple tuple)
|
Constructor and Description |
---|
BigdataMap.Entry(ITuple tuple) |
DelegateTuple(ITuple<E> delegate) |
Modifier and Type | Method and Description |
---|---|
protected ITuple<E> |
TupleFilter.TupleFilterator.getNext()
One step look ahead.
|
protected ITuple<String> |
TestPrefixFilter.newTestTuple(String s) |
ITuple<E> |
Reverserator.next() |
ITuple |
EmptyTupleIterator.next() |
ITuple<E> |
WrappedTupleIterator.next() |
ITuple<E> |
TupleFilter.TupleFilterator.next() |
ITuple<E> |
Reverserator.prior() |
ITuple<E> |
Reverserator.seek(byte[] key) |
ITuple<E> |
Reverserator.seek(Object key) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
Advancer.advance(ITuple<E> tuple)
Offers an opportunity to advance the source
ITupleCursor to a
new key using {@link ITupleCursor#seek(byte[]). |
protected abstract boolean |
TupleFilter.isValid(ITuple<E> tuple) |
protected abstract boolean |
TupleRemover.remove(ITuple<E> e)
true iff the tuple should be removed from the source
IIndex . |
protected abstract void |
TupleUpdater.update(IIndex ndx,
ITuple<E> tuple)
You may implement this method to update the state of the visited
tuple in the backing index.
|
protected void |
TupleFilter.TupleFilterator.visit(ITuple<E> tuple)
Hook for subclasses.
|
protected void |
TupleUpdater.Updaterator.visit(ITuple<E> tuple) |
Modifier and Type | Method and Description |
---|---|
boolean |
TestConflictResolution.SingleValueConflictResolver.resolveConflict(IIndex writeSet,
ITuple txTuple,
ITuple currentTuple) |
boolean |
TestConflictResolution.SingleValueConflictResolver.resolveConflict(IIndex writeSet,
ITuple txTuple,
ITuple currentTuple) |
boolean |
IConflictResolver.resolveConflict(IIndex writeSet,
ITuple txTuple,
ITuple currentTuple)
Resolve a write-write conflict between a committed version on the journal
and the current version within a transaction that is validating.
|
boolean |
IConflictResolver.resolveConflict(IIndex writeSet,
ITuple txTuple,
ITuple currentTuple)
Resolve a write-write conflict between a committed version on the journal
and the current version within a transaction that is validating.
|
boolean |
NoConflictResolver.resolveConflict(IIndex writeSet,
ITuple txTuple,
ITuple currentTuple) |
boolean |
NoConflictResolver.resolveConflict(IIndex writeSet,
ITuple txTuple,
ITuple currentTuple) |
Modifier and Type | Field and Description |
---|---|
protected ITuple<E>[] |
FusedTupleIterator.sourceTuple
|
Modifier and Type | Method and Description |
---|---|
protected ITuple<E> |
FusedTupleCursor.consumeLookaheadTuple()
Extended to make a copy of the key for each visited tuple.
|
protected ITuple<E> |
FusedTupleIterator.consumeLookaheadTuple()
Consume the
FusedTupleIterator.current source ITuple . |
ITuple<E> |
FusedTupleIterator.next() |
ITuple<E> |
FusedTupleCursor.prior() |
ITuple<E> |
FusedTupleCursor.seek(byte[] key) |
ITuple<E> |
FusedTupleCursor.seek(Object key) |
Modifier and Type | Method and Description |
---|---|
protected void |
TestFusedView.assertEquals(ITuple expected,
ITuple actual)
Compares
ITuple s for equality in their data. |
protected void |
TestFusedView.assertEquals(ITuple expected,
ITuple actual)
Compares
ITuple s for equality in their data. |
Modifier and Type | Method and Description |
---|---|
CounterSetBTree.Entry |
CounterSetBTree.CounterSetBTreeTupleSerializer.deserialize(ITuple tuple) |
Modifier and Type | Method and Description |
---|---|
CommitRecordIndex.Entry |
CommitRecordIndex.CommitRecordIndexTupleSerializer.deserialize(ITuple tuple) |
Name2Addr.Entry |
Name2Addr.Name2AddrTupleSerializer.deserialize(ITuple tuple) |
Long |
CommitRecordIndex.CommitRecordIndexTupleSerializer.deserializeKey(ITuple tuple)
Decodes the key as a commit time.
|
Modifier and Type | Method and Description |
---|---|
BigdataValue |
BlobsTupleSerializer.deserialize(ITuple tuple)
De-serializes the
ITuple as a BigdataValue , including
the term identifier extracted from the unsigned byte[] key, and sets
the appropriate BigdataValueFactoryImpl reference on that object. |
BigdataValue |
Id2TermTupleSerializer.deserialize(ITuple tuple)
De-serializes the
ITuple as a BigdataValue , including
the term identifier extracted from the unsigned byte[] key, and sets
the appropriate BigdataValueFactoryImpl reference on that object. |
ITermDocRecord |
RDFFullTextIndexTupleSerializer.deserialize(ITuple tuple) |
IV |
Term2IdTupleSerializer.deserialize(ITuple tuple)
|
protected ITermDocKey |
RDFFullTextIndexTupleSerializer.deserialize(ITuple tuple,
boolean keyOnly) |
IV |
BlobsTupleSerializer.deserializeKey(ITuple tuple)
Decodes the key to a
BlobIV . |
IV |
Id2TermTupleSerializer.deserializeKey(ITuple tuple)
Decodes the term identifier key to a term identifier.
|
ITermDocKey |
RDFFullTextIndexTupleSerializer.deserializeKey(ITuple tuple) |
Object |
Term2IdTupleSerializer.deserializeKey(ITuple tuple)
You can not decode the term:id keys since they include Unicode sort keys
and that is a lossy transform.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
GeoSpatialServiceFactory.GeoSpatialFilterBase.isValid(ITuple tuple) |
protected abstract boolean |
GeoSpatialServiceFactory.GeoSpatialFilterBase.isValidInternal(ITuple tuple)
Check if the iv array is valid.
|
protected boolean |
GeoSpatialServiceFactory.GeoSpatialInCircleFilter.isValidInternal(ITuple tuple) |
protected boolean |
GeoSpatialServiceFactory.AcceptAllSolutionsFilter.isValidInternal(ITuple tuple) |
Modifier and Type | Method and Description |
---|---|
HistoryChangeRecord |
HistoryIndexTupleSerializer.deserialize(ITuple tuple) |
HistoryChangeRecord |
HistoryIndexTupleSerializer.deserializeKey(ITuple tuple) |
Modifier and Type | Method and Description |
---|---|
protected void |
DistinctTermAdvancer.advance(ITuple<SPO> tuple) |
protected void |
DistinctMultiTermAdvancer.advance(ITuple<SPO> tuple) |
protected void |
ContextAdvancer.advance(ITuple<SPO> tuple) |
SPO |
SPOTupleSerializer.deserialize(ITuple tuple) |
Justification |
JustificationTupleSerializer.deserialize(ITuple tuple) |
SPO |
SPOTupleSerializer.deserializeKey(ITuple tuple) |
Justification |
JustificationTupleSerializer.deserializeKey(ITuple tuple) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
SameVariableConstraintTupleFilter.isValid(ITuple tuple) |
boolean |
ElementFilter.isValid(ITuple<R> tuple) |
Modifier and Type | Method and Description |
---|---|
Long |
JournalIndex.TupleSerializer.deserializeKey(ITuple tuple)
Decodes the key as a commit time.
|
Modifier and Type | Method and Description |
---|---|
ITermDocRecord<V> |
FullTextIndexTupleSerializer.deserialize(ITuple tuple) |
protected ITermDocKey<V> |
FullTextIndexTupleSerializer.deserialize(ITuple tuple,
boolean keyOnly) |
ITermDocKey<V> |
FullTextIndexTupleSerializer.deserializeKey(ITuple tuple) |
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.
|
ITxState0 |
TxId2CommitTimeIndex.TupleSerializer.deserialize(ITuple tuple)
Decodes the value as a commit time.
|
Long |
CommitTimeIndex.TupleSerializer.deserializeKey(ITuple tuple)
Decodes the key as a commit time.
|
Long |
EventReceiver.EventBTree.EventBTreeTupleSerializer.deserializeKey(ITuple tuple)
Decodes the key as a timestamp.
|
Long |
TxId2CommitTimeIndex.TupleSerializer.deserializeKey(ITuple tuple)
Decodes the key as a transaction identifier.
|
static boolean |
TestRangeQuery.sameTuple(ITuple<?> expected,
ITuple<?> actual)
Compares two tuples for equality based on their data (flags, keys,
values, deleted marker, and version timestamp).
|
static boolean |
TestRangeQuery.sameTuple(ITuple<?> expected,
ITuple<?> actual)
Compares two tuples for equality based on their data (flags, keys,
values, deleted marker, and version timestamp).
|
Modifier and Type | Method and Description |
---|---|
protected void |
ZOrderIndexBigMinAdvancer.advance(ITuple<SPO> tuple) |
Modifier and Type | Method and Description |
---|---|
ITuple<E> |
PartitionedTupleIterator.next() |
Modifier and Type | Method and Description |
---|---|
TPS |
TPSTupleSerializer.deserialize(ITuple tuple) |
Void |
TPSTupleSerializer.deserializeKey(ITuple tuple)
You can get the
Schema and the primary key from
TPSTupleSerializer.deserialize(ITuple) . |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.