public class MySqlSnapshotSplitReadTask
extends io.debezium.pipeline.source.AbstractSnapshotChangeEventSource
| Constructor and Description |
|---|
MySqlSnapshotSplitReadTask(io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig,
io.debezium.connector.mysql.MySqlOffsetContext previousOffset,
io.debezium.pipeline.source.spi.SnapshotProgressListener snapshotProgressListener,
io.debezium.connector.mysql.MySqlDatabaseSchema databaseSchema,
io.debezium.connector.mysql.MySqlConnection jdbcConnection,
EventDispatcherImpl<io.debezium.relational.TableId> dispatcher,
io.debezium.schema.TopicSelector<io.debezium.relational.TableId> topicSelector,
io.debezium.util.Clock clock,
MySqlSnapshotSplit snapshotSplit) |
| Modifier and Type | Method and Description |
|---|---|
protected io.debezium.pipeline.spi.SnapshotResult |
doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context,
io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext snapshotContext,
io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask) |
io.debezium.pipeline.spi.SnapshotResult |
execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context) |
protected io.debezium.pipeline.spi.ChangeRecordEmitter |
getChangeRecordEmitter(io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext snapshotContext,
io.debezium.relational.TableId tableId,
Object[] row) |
protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask |
getSnapshottingTask(io.debezium.pipeline.spi.OffsetContext previousOffset) |
protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext |
prepare(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext changeEventSourceContext) |
public MySqlSnapshotSplitReadTask(io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig,
io.debezium.connector.mysql.MySqlOffsetContext previousOffset,
io.debezium.pipeline.source.spi.SnapshotProgressListener snapshotProgressListener,
io.debezium.connector.mysql.MySqlDatabaseSchema databaseSchema,
io.debezium.connector.mysql.MySqlConnection jdbcConnection,
EventDispatcherImpl<io.debezium.relational.TableId> dispatcher,
io.debezium.schema.TopicSelector<io.debezium.relational.TableId> topicSelector,
io.debezium.util.Clock clock,
MySqlSnapshotSplit snapshotSplit)
public io.debezium.pipeline.spi.SnapshotResult execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context)
throws InterruptedException
execute in interface io.debezium.pipeline.source.spi.SnapshotChangeEventSourceexecute in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSourceInterruptedExceptionprotected io.debezium.pipeline.spi.SnapshotResult doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context,
io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext snapshotContext,
io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask)
throws Exception
doExecute in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSourceExceptionprotected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask getSnapshottingTask(io.debezium.pipeline.spi.OffsetContext previousOffset)
getSnapshottingTask in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSourceprotected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext prepare(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext changeEventSourceContext)
throws Exception
prepare in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSourceExceptionprotected io.debezium.pipeline.spi.ChangeRecordEmitter getChangeRecordEmitter(io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext snapshotContext,
io.debezium.relational.TableId tableId,
Object[] row)
Copyright © 2022 The Apache Software Foundation. All rights reserved.