com.taobao.common.store.journal
类 DataFileAppender

java.lang.Object
  com.taobao.common.store.journal.DataFileAppender

public class DataFileAppender
extends Object

字段摘要

protected Map<BytesKey,JournalStore.InflyWriteData>	inflyWrites
protected int	maxWriteBatchSize

构造方法摘要

DataFileAppender(JournalStore journalStore)

方法摘要

void	close()
byte[]	getDataFromInFlyWrites(BytesKey key)
void	processQueue()
OpItem	remove(OpItem opItem, BytesKey bytesKey, boolean sync)
OpItem	store(OpItem opItem, BytesKey bytesKey, byte[] data, boolean sync)
void	sync()

从类 java.lang.Object 继承的方法

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细信息

maxWriteBatchSize

protected int maxWriteBatchSize

inflyWrites

protected final Map<BytesKey,JournalStore.InflyWriteData> inflyWrites

构造方法详细信息

DataFileAppender

public DataFileAppender(JournalStore journalStore)

方法详细信息

remove

public OpItem remove(OpItem opItem,
                     BytesKey bytesKey,
                     boolean sync)
              throws IOException

抛出：

IOException

store

public OpItem store(OpItem opItem,
                    BytesKey bytesKey,
                    byte[] data,
                    boolean sync)
             throws IOException

抛出：

IOException

close

public void close()

processQueue

public void processQueue()

getDataFromInFlyWrites

public byte[] getDataFromInFlyWrites(BytesKey key)

sync

public void sync()