Package com.zendesk.maxwell.row

Class RowMapBufferByTable

java.lang.Object

com.zendesk.maxwell.row.RowMapBufferByTable

public class RowMapBufferByTable
extends Object

Constructor Summary

Constructors

Constructor	Description
RowMapBufferByTable()

Method Summary

Modifier and Type	Method	Description
void	add(RowMap row)
void	flushToDisk(String databaseName, String tableName)
RowMap	removeFirst(String databaseName, String tableName)
Long	size(String databaseName, String tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

RowMapBufferByTable

public RowMapBufferByTable()

Method Detail

add

public void add(RowMap row)
         throws IOException

Throws:

IOException

removeFirst

public RowMap removeFirst(String databaseName,
                          String tableName)
                   throws IOException,
                          ClassNotFoundException

Throws:

IOException

ClassNotFoundException

size

public Long size(String databaseName,
                 String tableName)
          throws IOException

Throws:

IOException

flushToDisk

public void flushToDisk(String databaseName,
                        String tableName)
                 throws IOException

Throws:

IOException