StreamSrcPlugin

class

class StreamSrcPlugin

Bases: ABC

Categories: spi

Plugin implementing the long-running side of a StreamSrc subclass (CDC, log tail, queue tail).

Methods

method

run

def run(ctx: StreamSrcPluginCtx, conn: C, stream_src: SS)

Drive the change stream until ctx.active flips to False or a signal arrives. Implementations seed from config when ctx.first_stage else from ctx.stream_state, then call ctx.stage for batches as they complete (honouring ctx.flush_interval_mins).

Parameters:

parameter

ctxStreamSrcPluginCtx

parameter

connC

parameter

stream_srcSS