| 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,
        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. | 
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 © 2016 The Apache Software Foundation. All rights reserved.