Package io.debezium.pipeline

Class ChangeEventSourceCoordinator.ChangeEventSourceContextImpl

java.lang.Object

io.debezium.pipeline.ChangeEventSourceCoordinator.ChangeEventSourceContextImpl

All Implemented Interfaces:

ChangeEventSource.ChangeEventSourceContext

Enclosing class:

ChangeEventSourceCoordinator<P extends Partition,O extends OffsetContext>

public class ChangeEventSourceCoordinator.ChangeEventSourceContextImpl
extends Object
implements ChangeEventSource.ChangeEventSourceContext

Field Summary

Fields

Modifier and Type	Field	Description
private final Lock	lock
private final Condition	snapshotFinished
private final Condition	streamingPaused
private final Condition	streamingRunning

Constructor Summary

Constructors

Constructor	Description
ChangeEventSourceContextImpl()

Method Summary

Modifier and Type	Method	Description
boolean	isPaused()	Whether this source is paused.
boolean	isRunning()	Whether this source is running or has been requested to stop.
void	resumeStreaming()	Called to indicate that the snapshot has been completed and that streaming should therefore continue.
void	streamingPaused()	Called by the StreamingChangeEventSource to indicate that the streaming has now been paused, and that no streaming records are being processed anymore.
void	waitSnapshotCompletion()	Wait for the resumeStreaming function to be called, which indicates that a snapshot is done and that streaming should resume.
void	waitStreamingPaused()	Wait for the streamingPaused function to be called.

Methods inherited from class java.lang.Object

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

Field Details

lock

private final Lock lock

snapshotFinished

private final Condition snapshotFinished

streamingPaused

private final Condition streamingPaused

streamingRunning

private final Condition streamingRunning

Constructor Details

ChangeEventSourceContextImpl

public ChangeEventSourceContextImpl()

Method Details

isPaused

public boolean isPaused()

Description copied from interface: ChangeEventSource.ChangeEventSourceContext

Whether this source is paused.

Specified by:

isPaused in interface ChangeEventSource.ChangeEventSourceContext

isRunning

public boolean isRunning()

Description copied from interface: ChangeEventSource.ChangeEventSourceContext

Whether this source is running or has been requested to stop.

Specified by:

isRunning in interface ChangeEventSource.ChangeEventSourceContext

resumeStreaming

public void resumeStreaming()
                     throws InterruptedException

Description copied from interface: ChangeEventSource.ChangeEventSourceContext

Called to indicate that the snapshot has been completed and that streaming should therefore continue.

Specified by:

resumeStreaming in interface ChangeEventSource.ChangeEventSourceContext

Throws:

InterruptedException

waitSnapshotCompletion

public void waitSnapshotCompletion()
                            throws InterruptedException

Description copied from interface: ChangeEventSource.ChangeEventSourceContext

Wait for the resumeStreaming function to be called, which indicates that a snapshot is done and that streaming should resume.

Specified by:

waitSnapshotCompletion in interface ChangeEventSource.ChangeEventSourceContext

Throws:

InterruptedException

streamingPaused

public void streamingPaused()

Description copied from interface: ChangeEventSource.ChangeEventSourceContext

Called by the StreamingChangeEventSource to indicate that the streaming has now been paused, and that no streaming records are being processed anymore.

Specified by:

streamingPaused in interface ChangeEventSource.ChangeEventSourceContext

waitStreamingPaused

public void waitStreamingPaused()
                         throws InterruptedException

Description copied from interface: ChangeEventSource.ChangeEventSourceContext

Wait for the streamingPaused function to be called.

Specified by:

waitStreamingPaused in interface ChangeEventSource.ChangeEventSourceContext

Throws:

InterruptedException