Package com.zendesk.maxwell.bootstrap

Class SynchronousBootstrapper

java.lang.Object

com.zendesk.maxwell.bootstrap.SynchronousBootstrapper

public class SynchronousBootstrapper
extends Object

Does the bulk of the actual bootstrapping work

Constructor Summary

Constructors

Constructor	Description
SynchronousBootstrapper(MaxwellContext context)

Method Summary

Modifier and Type	Method	Description
void	completeBootstrap(BootstrapTask task, AbstractProducer producer)	Output a "bootstrap complete" row
void	performBootstrap(BootstrapTask task, AbstractProducer producer, Long currentSchemaID)	Perform bootstrap; query all rows from the table in question, and stream the results from the database into the producer.
void	startBootstrap(BootstrapTask task, AbstractProducer producer, Long currentSchemaID)	Orchestrates the bootstrap process.

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronousBootstrapper

public SynchronousBootstrapper(MaxwellContext context)

Method Detail

startBootstrap

public void startBootstrap(BootstrapTask task,
                           AbstractProducer producer,
                           Long currentSchemaID)
                    throws Exception

Orchestrates the bootstrap process.

Parameters:

task - the bootstrap task

producer - a producer to push rows to

currentSchemaID - the current schema id

Throws:

Exception

performBootstrap

public void performBootstrap(BootstrapTask task,
                             AbstractProducer producer,
                             Long currentSchemaID)
                      throws Exception

Perform bootstrap; query all rows from the table in question, and stream the results from the database into the producer. Periodically we update the `inserted_rows` column in the boostrapping table.

Parameters:

task - bootstrap task

producer - current producer

currentSchemaID - current schema id

Throws:

Exception

completeBootstrap

public void completeBootstrap(BootstrapTask task,
                              AbstractProducer producer)
                       throws Exception

Output a "bootstrap complete" row

Parameters:

task - bootstrap task

producer - current producer

Throws:

Exception