Package io.debezium.snapshot.mode

Class ConfigurationBasedSnapshotter

java.lang.Object

io.debezium.snapshot.mode.BeanAwareSnapshotter

io.debezium.snapshot.mode.ConfigurationBasedSnapshotter

All Implemented Interfaces:

BeanRegistryAware, io.debezium.spi.common.Configurable, io.debezium.spi.snapshot.Snapshotter

public class ConfigurationBasedSnapshotter
extends BeanAwareSnapshotter
implements io.debezium.spi.snapshot.Snapshotter

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	snapshotData
private boolean	snapshotOnDataError
private boolean	snapshotOnSchemaError
private boolean	snapshotSchema
private boolean	stream

Fields inherited from class io.debezium.snapshot.mode.BeanAwareSnapshotter

beanRegistry

Constructor Summary

Constructors

Constructor	Description
ConfigurationBasedSnapshotter()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> properties)
String	name()
boolean	shouldSnapshotData(boolean offsetExists, boolean snapshotInProgress)
boolean	shouldSnapshotOnDataError()
boolean	shouldSnapshotOnSchemaError()
boolean	shouldSnapshotSchema(boolean offsetExists, boolean snapshotInProgress)
boolean	shouldStream()

Methods inherited from class io.debezium.snapshot.mode.BeanAwareSnapshotter

injectBeanRegistry

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.spi.snapshot.Snapshotter

shouldStreamEventsStartingFromSnapshot, snapshotAborted, snapshotCompleted

Field Details

snapshotData

private boolean snapshotData

snapshotSchema

private boolean snapshotSchema

stream

private boolean stream

snapshotOnSchemaError

private boolean snapshotOnSchemaError

snapshotOnDataError

private boolean snapshotOnDataError

Constructor Details

ConfigurationBasedSnapshotter

public ConfigurationBasedSnapshotter()

Method Details

name

public String name()

Specified by:

name in interface io.debezium.spi.snapshot.Snapshotter

configure

public void configure(Map<String,?> properties)

Specified by:

configure in interface io.debezium.spi.common.Configurable

shouldSnapshotData

public boolean shouldSnapshotData(boolean offsetExists,
 boolean snapshotInProgress)

Specified by:

shouldSnapshotData in interface io.debezium.spi.snapshot.Snapshotter

shouldSnapshotSchema

public boolean shouldSnapshotSchema(boolean offsetExists,
 boolean snapshotInProgress)

Specified by:

shouldSnapshotSchema in interface io.debezium.spi.snapshot.Snapshotter

shouldStream

public boolean shouldStream()

Specified by:

shouldStream in interface io.debezium.spi.snapshot.Snapshotter

shouldSnapshotOnSchemaError

public boolean shouldSnapshotOnSchemaError()

Specified by:

shouldSnapshotOnSchemaError in interface io.debezium.spi.snapshot.Snapshotter

shouldSnapshotOnDataError

public boolean shouldSnapshotOnDataError()

Specified by:

shouldSnapshotOnDataError in interface io.debezium.spi.snapshot.Snapshotter