Package com.zendesk.maxwell

Class BufferedMaxwell

java.lang.Object

com.zendesk.maxwell.Maxwell

com.zendesk.maxwell.BufferedMaxwell

All Implemented Interfaces:

Runnable

public class BufferedMaxwell
extends Maxwell

A subclass of Maxwell that buffers rows in-memory for consumption by the caller

Field Summary

Fields inherited from class com.zendesk.maxwell.Maxwell

config, context, replicator

Constructor Summary

Constructors

Constructor	Description
BufferedMaxwell(MaxwellConfig config)	Initializer for a buffered Maxwell instance.

Method Summary

Modifier and Type	Method	Description
MaxwellContext	getContext()
RowMap	poll(long ms)	Poll for a RowMap to be producer by the maxwell instance.

Methods inherited from class com.zendesk.maxwell.Maxwell

getInitialPosition, getMaxwellVersion, main, onReplicatorEnd, onReplicatorStart, restart, run, start, terminate

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferedMaxwell

public BufferedMaxwell(MaxwellConfig config)
                throws SQLException,
                       URISyntaxException

Initializer for a buffered Maxwell instance. Sets up buffered producer.

Parameters:

config - Maxwell configuration

Throws:

SQLException - if we have db issues

URISyntaxException - if we can't build a database URI

Method Detail

poll

public RowMap poll(long ms)
            throws IOException,
                   InterruptedException

Poll for a RowMap to be producer by the maxwell instance.

Parameters:

ms - poll time to wait in milliseconds before timing out

Returns:

RowMap

Throws:

IOException - if we have issues building a producer

InterruptedException - if we are interrupted

getContext

public MaxwellContext getContext()