public interface TransactionStateStorage
extends com.google.common.util.concurrent.Service
Modifier and Type | Method and Description |
---|---|
TransactionLog |
createLog(long timestamp)
Creates a new
TransactionLog . |
void |
deleteLogsOlderThan(long timestamp)
Removes any transaction logs with a timestamp older than the given value.
|
long |
deleteOldSnapshots(int numberToKeep)
Removes any snapshots prior to the
numberToKeep most recent. |
TransactionSnapshot |
getLatestSnapshot()
Returns the most recent snapshot that has been successfully written.
|
TransactionVisibilityState |
getLatestTransactionVisibilityState()
Returns the most recent transaction visibility state that has been successfully written.
|
String |
getLocation()
Returns a string representation of the location used for persistence.
|
List<TransactionLog> |
getLogsSince(long timestamp)
Returns all
TransactionLog s with a timestamp greater than or equal to the given timestamp. |
List<String> |
listLogs()
Returns the (non-qualified) names of available logs.
|
List<String> |
listSnapshots()
Returns the (non-qualified) names of available snapshots.
|
void |
setupStorage()
Create the directories required for the transaction state stage.
|
void |
writeSnapshot(OutputStream out,
TransactionSnapshot snapshot)
Persists a snapshot of transaction state to an output stream.
|
void |
writeSnapshot(TransactionSnapshot snapshot)
Persists a snapshot of transaction state.
|
void writeSnapshot(OutputStream out, TransactionSnapshot snapshot) throws IOException
IOException
void writeSnapshot(TransactionSnapshot snapshot) throws IOException
IOException
TransactionSnapshot getLatestSnapshot() throws IOException
null
if no completed snapshot files are found.IOException
TransactionVisibilityState getLatestTransactionVisibilityState() throws IOException
null
if no completed snapshot files are found.TransactionVisibilityState
IOException
long deleteOldSnapshots(int numberToKeep) throws IOException
numberToKeep
most recent.numberToKeep
- The number of most recent snapshots to keep.IOException
- If an error occurs while deleting old snapshots.List<String> listSnapshots() throws IOException
IOException
List<TransactionLog> getLogsSince(long timestamp) throws IOException
TransactionLog
s with a timestamp greater than or equal to the given timestamp. Note that
the returned list is guaranteed to be sorted in ascending timestamp order.IOException
TransactionLog createLog(long timestamp) throws IOException
TransactionLog
.IOException
List<String> listLogs() throws IOException
IOException
void deleteLogsOlderThan(long timestamp) throws IOException
timestamp
- The timestamp to delete up to. Logs with a timestamp less than this value will be removed.IOException
- If an error occurs while removing logs.void setupStorage() throws IOException
IOException
- If an error occurred during the creation of required directories for transaction state storage.String getLocation()
Copyright © 2017 The Apache Software Foundation. All rights reserved.