@InterfaceAudience.Private public class EditsDoubleBuffer extends Object
Constructor and Description |
---|
EditsDoubleBuffer(int defaultBufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
countBufferedBytes() |
int |
countReadyBytes() |
int |
countReadyTxns() |
void |
flushTo(OutputStream out)
Writes the content of the "ready" buffer to the given output stream,
and resets it.
|
long |
getFirstReadyTxId() |
boolean |
isFlushed() |
void |
setReadyToFlush() |
boolean |
shouldForceSync() |
void |
writeOp(FSEditLogOp op) |
void |
writeRaw(byte[] bytes,
int offset,
int length) |
public void writeOp(FSEditLogOp op) throws IOException
IOException
public void writeRaw(byte[] bytes, int offset, int length) throws IOException
IOException
public void close() throws IOException
IOException
public void setReadyToFlush()
public void flushTo(OutputStream out) throws IOException
IOException
public boolean shouldForceSync()
public boolean isFlushed()
public int countBufferedBytes()
public long getFirstReadyTxId()
public int countReadyTxns()
public int countReadyBytes()
Copyright © 2013 Apache Software Foundation. All rights reserved.