public class ChecksummedTranslogStream extends Object implements TranslogStream
Modifier and Type | Field and Description |
---|---|
static int |
VERSION |
Modifier and Type | Method and Description |
---|---|
StreamInput |
openInput(File translogFile)
Seek past the header, if any header is present
|
Translog.Operation |
read(StreamInput inStream)
Read the next translog operation from the input stream
|
void |
write(StreamOutput outStream,
Translog.Operation op)
Write the given translog operation to the output stream
|
int |
writeHeader(FileChannel channel)
Optionally write a header identifying the translog version to the
file channel
|
public static final int VERSION
public Translog.Operation read(StreamInput inStream) throws IOException
TranslogStream
read
in interface TranslogStream
IOException
public void write(StreamOutput outStream, Translog.Operation op) throws IOException
TranslogStream
write
in interface TranslogStream
IOException
public int writeHeader(FileChannel channel) throws IOException
TranslogStream
writeHeader
in interface TranslogStream
IOException
public StreamInput openInput(File translogFile) throws IOException
TranslogStream
openInput
in interface TranslogStream
IOException
Copyright © 2009–2015. All rights reserved.