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