| 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.