public interface TransactionLogWriter extends Closeable
AbstractTransactionLog
.Modifier and Type | Method and Description |
---|---|
void |
append(AbstractTransactionLog.Entry entry)
Adds a new transaction entry to the log.
|
void |
commitMarker(int count)
Makes an entry of number of transaction entries that will follow in that log in a single sync.
|
void |
sync()
Syncs any pending transaction edits added through
append(AbstractTransactionLog.Entry) ,
but not yet flushed to durable storage. |
void append(AbstractTransactionLog.Entry entry) throws IOException
sync()
has been called.entry
- The transaction edit to append.IOException
- If an error occurs while writing the edit to storage.void commitMarker(int count) throws IOException
count
- Number of transaction entries.IOException
- If an error occurs while writing the count to storage.void sync() throws IOException
append(AbstractTransactionLog.Entry)
,
but not yet flushed to durable storage.IOException
- If an error occurs while flushing the outstanding edits.Copyright © 2017 The Apache Software Foundation. All rights reserved.