Package | Description |
---|---|
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
com.bigdata.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
Modifier and Type | Method and Description |
---|---|
protected AbstractTransactionService.TxState |
TestTransactionService.MockTransactionService.getEarliestActiveTx()
Return the
AbstractTransactionService.TxState for the earliest active Tx -or-
null if there is no active tx. |
protected AbstractTransactionService.TxState |
TestTransactionService.MockTransactionService.getTxState(long txId)
Return the
AbstractTransactionService.TxState associated with the specified transition
identifier. |
Modifier and Type | Method and Description |
---|---|
protected void |
TestTransactionService.MockTransactionService.abortImpl(AbstractTransactionService.TxState state) |
protected void |
JournalTransactionService.abortImpl(AbstractTransactionService.TxState state) |
protected void |
JournalTransactionService.activateTx(AbstractTransactionService.TxState state)
Extended to register the new tx in the
AbstractLocalTransactionManager . |
protected long |
TestTransactionService.MockTransactionService.commitImpl(AbstractTransactionService.TxState state) |
protected long |
JournalTransactionService.commitImpl(AbstractTransactionService.TxState state) |
protected void |
JournalTransactionService.deactivateTx(AbstractTransactionService.TxState state) |
Modifier and Type | Method and Description |
---|---|
protected AbstractTransactionService.TxState |
AbstractTransactionService.assignTransactionIdentifier(long timestamp)
Assign a transaction identifier for a new transaction.
|
protected AbstractTransactionService.TxState |
AbstractTransactionService.getEarliestActiveTx()
Return the
AbstractTransactionService.TxState for the earliest active Tx -or-
null if there is no active tx. |
protected AbstractTransactionService.TxState |
AbstractTransactionService.getTxState(long tx)
Return the
AbstractTransactionService.TxState associated with the specified transition
identifier. |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractTransactionService.abortImpl(AbstractTransactionService.TxState state)
Implementation must abort the tx on the journal (standalone) or on each
data service (federation) on which it has written.
|
protected void |
DistributedTransactionService.abortImpl(AbstractTransactionService.TxState state) |
protected void |
AbstractTransactionService.activateTx(AbstractTransactionService.TxState state)
Adds the transaction from to the local tables.
|
void |
TxId2CommitTimeIndex.add(AbstractTransactionService.TxState txState)
Add an entry.
|
protected abstract long |
AbstractTransactionService.commitImpl(AbstractTransactionService.TxState state)
Implementation must either single-phase commit (standalone journal or a
transaction that only writes on a single data service) or 2-/3-phase
commit (distributed transaction running on a federation).
|
protected long |
DistributedTransactionService.commitImpl(AbstractTransactionService.TxState state)
There are two distinct commit protocols depending on whether the
transaction write set is distributed across more than one
IDataService . |
protected void |
AbstractTransactionService.deactivateTx(AbstractTransactionService.TxState state)
Removes the transaction from the local tables.
|
protected long |
DistributedTransactionService.singlePhaseCommit(AbstractTransactionService.TxState state)
Prepare and commit a read-write transaction that has written on a single
data service.
|
protected void |
AbstractTransactionService.updateReleaseTime(long timestamp,
AbstractTransactionService.TxState deactivatedTx)
This method MUST be invoked each time a transaction completes with the
absolute value of the transaction identifier that has just been
deactivated.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.