Package | Description |
---|---|
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 |
---|---|
TPS |
AtomicRowDelete.apply(IIndex ndx)
An atomic read of the matching properties is performed and those
properties are then deleted atomically.
|
TPS |
AtomicRowWriteRead.apply(IIndex ndx)
If a property set was specified then do an atomic write of the property
set.
|
TPS |
AtomicRowRead.apply(IIndex ndx)
Atomic read.
|
protected static TPS |
AbstractAtomicRowReadOrWrite.atomicRead(IIndex ndx,
byte[] fromKey,
Schema schema,
long fromTime,
long toTime,
INameFilter filter,
TPS tps)
Alternative form useful when you have the raw key (unsigned byte[])
rather than a primary key (application object).
|
protected static TPS |
AbstractAtomicRowReadOrWrite.atomicRead(IIndex ndx,
Schema schema,
Object primaryKey,
long fromTime,
long toTime,
long writeTime,
INameFilter filter)
Atomic read on the index.
|
TPS |
TPS.currentRow()
Filters for the current row (most recent bindings)
|
TPS |
TPS.currentRow(INameFilter filter)
Filters for the current row (most recent bindings)
|
TPS |
TPSTupleSerializer.deserialize(ITuple tuple) |
TPS |
TPS.filter(INameFilter filter)
Filters for only those bindings that satisify the given filter.
|
TPS |
TPS.filter(long fromTime,
long toTime)
Filters for only those bindings whose timestamp is GTE to the given
timestamp.
|
TPS |
TPS.filter(long fromTime,
long toTime,
INameFilter filter)
Filters for only those bindings whose timestamp is GTE to the given
timestamp and which satisify the optional property name filter.
|
TPS |
SparseRowStore.write(Schema schema,
Map<String,Object> propertySet,
long writeTime,
INameFilter filter,
IPrecondition precondition)
Atomic write with atomic read of the then current post-condition state of
the logical row.
|
TPS |
SparseRowStore.write(Schema schema,
Map<String,Object> propertySet,
long fromTime,
long toTime,
long writeTime,
INameFilter filter,
IPrecondition precondition)
Atomic write with atomic read of the post-condition state of the logical
row.
|
Modifier and Type | Method and Description |
---|---|
static ITupleSerializer<Void,TPS> |
TPSTupleSerializer.newInstance() |
protected ITupleIterator<TPS> |
AtomicRowFilter.newTransformer(LookaheadTupleFilter.ILookaheadTupleIterator<TPS.TPV> src,
Object context) |
Modifier and Type | Method and Description |
---|---|
protected void |
TestTPS.assertEquals(TPS expected,
TPS actual)
Asserts the same schema and the same tuples.
|
protected void |
TestTPS.assertRoundTrip(TPS expected)
Test helper for (de-)serialization tests.
|
protected static TPS |
AbstractAtomicRowReadOrWrite.atomicRead(IIndex ndx,
byte[] fromKey,
Schema schema,
long fromTime,
long toTime,
INameFilter filter,
TPS tps)
Alternative form useful when you have the raw key (unsigned byte[])
rather than a primary key (application object).
|
byte[] |
TPSTupleSerializer.serializeVal(TPS obj) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.