| Package | Description | 
|---|---|
| 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. 
 | 
| org.apache.tephra.snapshot | 
 This package contains interfaces and implementations for encoding and decoding transaction snapshots. 
 | 
| org.apache.tephra.util | 
| Modifier and Type | Method and Description | 
|---|---|
static Map<Long,TransactionManager.InProgressTx> | 
TransactionManager.txnBackwardsCompatCheck(int defaultLongTimeout,
                       long longTimeoutTolerance,
                       Map<Long,TransactionManager.InProgressTx> inProgress)
Check if in-progress transactions need to be migrated to have expiration time and type, if so do the migration. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Map<Long,TransactionManager.InProgressTx> | 
TransactionManager.txnBackwardsCompatCheck(int defaultLongTimeout,
                       long longTimeoutTolerance,
                       Map<Long,TransactionManager.InProgressTx> inProgress)
Check if in-progress transactions need to be migrated to have expiration time and type, if so do the migration. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
NavigableMap<Long,TransactionManager.InProgressTx> | 
TransactionVisibilityState.getInProgress()
Returns the map of write pointers to in-progress transactions at the time of the snapshot. 
 | 
NavigableMap<Long,TransactionManager.InProgressTx> | 
TransactionSnapshot.getInProgress()  | 
| 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. | 
| Constructor and Description | 
|---|
TransactionSnapshot(long timestamp,
                   long readPointer,
                   long writePointer,
                   Collection<Long> invalid,
                   NavigableMap<Long,TransactionManager.InProgressTx> inProgress)  | 
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)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected NavigableMap<Long,TransactionManager.InProgressTx> | 
SnapshotCodecV4.decodeInProgress(BinaryDecoder decoder)  | 
protected NavigableMap<Long,TransactionManager.InProgressTx> | 
SnapshotCodecV2.decodeInProgress(BinaryDecoder decoder)  | 
protected NavigableMap<Long,TransactionManager.InProgressTx> | 
DefaultSnapshotCodec.decodeInProgress(BinaryDecoder decoder)
Deprecated.  
  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
SnapshotCodecV4.encodeInProgress(BinaryEncoder encoder,
                Map<Long,TransactionManager.InProgressTx> inProgress)  | 
protected void | 
SnapshotCodecV2.encodeInProgress(BinaryEncoder encoder,
                Map<Long,TransactionManager.InProgressTx> inProgress)  | 
protected void | 
DefaultSnapshotCodec.encodeInProgress(BinaryEncoder encoder,
                Map<Long,TransactionManager.InProgressTx> inProgress)
Deprecated.  
  | 
| Modifier and Type | Method and Description | 
|---|---|
static long | 
TxUtils.getFirstShortInProgress(Map<Long,TransactionManager.InProgressTx> inProgress)
Returns the write pointer for the first "short" transaction that in the in-progress set, or
  
Transaction.NO_TX_IN_PROGRESS if none. | 
Copyright © 2016 The Apache Software Foundation. All rights reserved.