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.