Package | Description |
---|---|
co.cask.tephra.persist | |
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> |
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 TransactionSnapshot |
TransactionSnapshot.copyFrom(long snapshotTime,
long readPointer,
long writePointer,
Collection<Long> invalid,
NavigableMap<Long,TransactionManager.InProgressTx> inProgress,
Map<Long,Set<ChangeId>> committing,
NavigableMap<Long,Set<ChangeId>> committed)
Creates a new
TransactionSnapshot instance with copies of all of the individual collections. |
static TransactionSnapshot |
TransactionSnapshot.copyFrom(long snapshotTime,
long readPointer,
long writePointer,
Collection<Long> invalid,
NavigableMap<Long,TransactionManager.InProgressTx> inProgress,
Map<Long,Set<ChangeId>> committing,
NavigableMap<Long,Set<ChangeId>> committed)
Creates a new
TransactionSnapshot instance with copies of all of the individual collections. |
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) |
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) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.