| Package | Description | 
|---|---|
| org.apache.tephra.persist | 
 This package contains interfaces and implementations for persisting transaction state. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractTransactionLog
Common implementation of a transaction log, backed by file reader and writer based storage. 
 | 
class  | 
HDFSTransactionLog
Allows reading from and writing to a transaction write-ahead log stored in HDFS. 
 | 
class  | 
LocalFileTransactionLog
Reads and writes transaction logs against files in the local filesystem. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
TransactionLog | 
TransactionStateStorage.createLog(long timestamp)
Creates a new  
TransactionLog. | 
TransactionLog | 
NoOpTransactionStateStorage.createLog(long timestamp)  | 
TransactionLog | 
LocalFileTransactionStateStorage.createLog(long timestamp)  | 
TransactionLog | 
HDFSTransactionStateStorage.createLog(long timestamp)  | 
| Modifier and Type | Method and Description | 
|---|---|
List<TransactionLog> | 
TransactionStateStorage.getLogsSince(long timestamp)
Returns all  
TransactionLogs with a timestamp greater than or equal to the given timestamp. | 
List<TransactionLog> | 
NoOpTransactionStateStorage.getLogsSince(long timestamp)  | 
List<TransactionLog> | 
LocalFileTransactionStateStorage.getLogsSince(long timestamp)  | 
List<TransactionLog> | 
HDFSTransactionStateStorage.getLogsSince(long timestamp)  | 
Copyright © 2018 The Apache Software Foundation. All rights reserved.