@InterfaceAudience.Private public interface WALStreamReader extends Closeable
WALTailingReader
instead.WALTailingReader
Modifier and Type | Method and Description |
---|---|
void |
close()
Override to remove the 'throws IOException' as we are just a reader.
|
long |
getPosition()
Get the current reading position.
|
default WAL.Entry |
next()
Read the next entry in WAL.
|
WAL.Entry |
next(WAL.Entry reuse)
Read the next entry in WAL, use the given
WAL.Entry if not null to hold the
data. |
default WAL.Entry next() throws IOException
IOException
WAL.Entry next(WAL.Entry reuse) throws IOException
WAL.Entry
if not null
to hold the
data.
Mainly used in MR.reuse
- the entry to be used for reading, can be null
IOException
long getPosition() throws IOException
IOException
void close()
close
in interface AutoCloseable
close
in interface Closeable
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.