Package | Description |
---|---|
co.cask.tephra.persist | |
org.apache.tephra |
This package contains implementations of the transaction system v2.
|
org.apache.tephra.persist |
This package contains interfaces and implementations for persisting transaction state.
|
Modifier and Type | Method and Description |
---|---|
Set<ChangeId> |
TransactionEdit.getChanges()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static TransactionEdit |
TransactionEdit.createCommitted(long writePointer,
Set<ChangeId> changes,
long nextWritePointer,
boolean canCommit)
Deprecated.
Creates a new instance in the
TransactionEdit.State.COMMITTED state. |
static TransactionEdit |
TransactionEdit.createCommitting(long writePointer,
Set<ChangeId> changes)
Deprecated.
Creates a new instance in the
TransactionEdit.State.COMMITTING state. |
Modifier and Type | Method and Description |
---|---|
Set<ChangeId> |
TransactionManager.ChangeSet.getChangeIds() |
Modifier and Type | Method and Description |
---|---|
Set<ChangeId> |
TransactionEdit.getChanges() |
Map<Long,Set<ChangeId>> |
TransactionSnapshot.getCommittedChangeSets()
Returns a map of transaction write pointer to set of changed row keys for transaction that had successfully called
InMemoryTransactionManager.commit(Transaction) at the time of the snapshot. |
Map<Long,Set<ChangeId>> |
TransactionSnapshot.getCommittingChangeSets()
Returns a map of transaction write pointer to sets of changed row keys for transactions that had called
InMemoryTransactionManager.canCommit(Transaction, Collection) but not yet called
InMemoryTransactionManager.commit(Transaction) at the time of the snapshot. |
Modifier and Type | Method and Description |
---|---|
static TransactionEdit |
TransactionEdit.createCommitted(long writePointer,
Set<ChangeId> changes,
long nextWritePointer,
boolean canCommit)
Creates a new instance in the
TransactionEdit.State.COMMITTED state. |
static TransactionEdit |
TransactionEdit.createCommitting(long writePointer,
Set<ChangeId> changes)
Creates a new instance in the
TransactionEdit.State.COMMITTING state. |
Constructor and Description |
---|
TransactionSnapshot(long timestamp,
long readPointer,
long writePointer,
Collection<Long> invalid,
NavigableMap<Long,TransactionManager.InProgressTx> inProgress,
Map<Long,Set<ChangeId>> committing,
Map<Long,Set<ChangeId>> committed)
Creates an instance of TransactionSnapshot with the given transaction state
|
TransactionSnapshot(long timestamp,
long readPointer,
long writePointer,
Collection<Long> invalid,
NavigableMap<Long,TransactionManager.InProgressTx> inProgress,
Map<Long,Set<ChangeId>> committing,
Map<Long,Set<ChangeId>> committed)
Creates an instance of TransactionSnapshot with the given transaction state
|
Copyright © 2018 The Apache Software Foundation. All rights reserved.