Package com.zendesk.maxwell.row

Class RowMapBuffer

java.lang.Object

com.zendesk.maxwell.util.ListWithDiskBuffer<RowMap>

com.zendesk.maxwell.row.RowMapBuffer

public class RowMapBuffer
extends ListWithDiskBuffer<RowMap>

Constructor Summary

Constructors

Constructor	Description
RowMapBuffer(long maxInMemoryElements)
RowMapBuffer(long maxInMemoryElements, float bufferMemoryUsage)
RowMapBuffer(long maxInMemoryElements, long maxMemory)

Method Summary

Modifier and Type	Method	Description
void	add(RowMap rowMap)
protected RowMap	evict()
RowMap	removeFirst()
void	setSchemaId(Long schemaId)
void	setServerId(Long serverId)
void	setThreadId(Long threadId)
void	setXid(Long xid)
protected boolean	shouldBuffer()

Methods inherited from class com.zendesk.maxwell.util.ListWithDiskBuffer

finalize, flushToDisk, getLast, inMemorySize, isEmpty, removeFirst, resetOutputStreamCaches, size

Methods inherited from class java.lang.Object

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

Constructor Detail

RowMapBuffer

public RowMapBuffer(long maxInMemoryElements)

RowMapBuffer

public RowMapBuffer(long maxInMemoryElements,
                    long maxMemory)

RowMapBuffer

public RowMapBuffer(long maxInMemoryElements,
                    float bufferMemoryUsage)

Method Detail

add

public void add(RowMap rowMap)
         throws IOException

Overrides:

add in class ListWithDiskBuffer<RowMap>

Throws:

IOException

shouldBuffer

protected boolean shouldBuffer()

Overrides:

shouldBuffer in class ListWithDiskBuffer<RowMap>

evict

protected RowMap evict()
                throws IOException

Overrides:

evict in class ListWithDiskBuffer<RowMap>

Throws:

IOException

removeFirst

public RowMap removeFirst()
                   throws IOException,
                          ClassNotFoundException

Throws:

IOException

ClassNotFoundException

setXid

public void setXid(Long xid)

setServerId

public void setServerId(Long serverId)

setThreadId

public void setThreadId(Long threadId)

setSchemaId

public void setSchemaId(Long schemaId)