public interface IRecordLogAppender<K,V>
| Modifier and Type | Method and Description |
|---|---|
void |
deleteDocs(Collection<K> ids) |
void |
flushWriter(Map<String,String> metadata) |
long |
getLastPosition() |
int |
getMaxSegment() |
File |
getSegmentPath(int segment) |
void |
putCheckpoint(long timestamp) |
long |
write(K key,
V value) |
long getLastPosition()
int getMaxSegment()
File getSegmentPath(int segment)
void deleteDocs(Collection<K> ids) throws IOException
IOExceptionlong write(K key, V value) throws IOException
IOExceptionvoid putCheckpoint(long timestamp)
throws IOException
IOExceptionvoid flushWriter(Map<String,String> metadata) throws IOException
IOExceptionCopyright © 2017. All Rights Reserved.