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.
|
Modifier and Type | Method and Description |
---|---|
TransactionSnapshot |
TransactionManager.getCurrentState() |
TransactionSnapshot |
TransactionManager.getSnapshot() |
Modifier and Type | Method and Description |
---|---|
static TransactionSnapshot |
TransactionSnapshot.copyFrom(long snapshotTime,
long readPointer,
long writePointer,
InvalidTxList invalidTxList,
NavigableMap<Long,TransactionManager.InProgressTx> inProgress,
Map<Long,TransactionManager.ChangeSet> committing,
NavigableMap<Long,TransactionManager.ChangeSet> committed)
Creates a new
TransactionSnapshot instance with copies of all of the individual collections. |
TransactionSnapshot |
TransactionStateStorage.getLatestSnapshot()
Returns the most recent snapshot that has been successfully written.
|
TransactionSnapshot |
NoOpTransactionStateStorage.getLatestSnapshot() |
TransactionSnapshot |
LocalFileTransactionStateStorage.getLatestSnapshot() |
TransactionSnapshot |
HDFSTransactionStateStorage.getLatestSnapshot() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionStateStorage.writeSnapshot(OutputStream out,
TransactionSnapshot snapshot)
Persists a snapshot of transaction state to an output stream.
|
void |
NoOpTransactionStateStorage.writeSnapshot(OutputStream out,
TransactionSnapshot snapshot) |
void |
AbstractTransactionStateStorage.writeSnapshot(OutputStream out,
TransactionSnapshot snapshot) |
void |
TransactionStateStorage.writeSnapshot(TransactionSnapshot snapshot)
Persists a snapshot of transaction state.
|
void |
NoOpTransactionStateStorage.writeSnapshot(TransactionSnapshot snapshot) |
void |
LocalFileTransactionStateStorage.writeSnapshot(TransactionSnapshot snapshot) |
void |
HDFSTransactionStateStorage.writeSnapshot(TransactionSnapshot snapshot) |
Modifier and Type | Method and Description |
---|---|
TransactionSnapshot |
SnapshotCodecProvider.decode(InputStream in) |
TransactionSnapshot |
SnapshotCodec.decode(InputStream in)
Decode a transaction snapshot from an input stream.
|
TransactionSnapshot |
DefaultSnapshotCodec.decode(InputStream in)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
SnapshotCodecProvider.encode(OutputStream out,
TransactionSnapshot snapshot) |
void |
SnapshotCodec.encode(OutputStream out,
TransactionSnapshot snapshot)
Encode a transaction snapshot into an output stream.
|
void |
DefaultSnapshotCodec.encode(OutputStream out,
TransactionSnapshot snapshot)
Deprecated.
|
Copyright © 2018 The Apache Software Foundation. All rights reserved.