Uses of Class
io.debezium.connector.common.CdcSourceTaskContext
Packages that use CdcSourceTaskContext
Package
Description
-
Uses of CdcSourceTaskContext in io.debezium.connector.common
Fields in io.debezium.connector.common declared as CdcSourceTaskContextModifier and TypeFieldDescriptionprivate CdcSourceTaskContext<? extends CommonConnectorConfig> BaseSourceTask.cdcSourceTaskContextprivate final CdcSourceTaskContextDebeziumHeaderProducer.sourceTaskContextMethods in io.debezium.connector.common that return CdcSourceTaskContextModifier and TypeMethodDescriptionabstract CdcSourceTaskContext<? extends CommonConnectorConfig> BaseSourceTask.preStart(io.debezium.config.Configuration config) Constructors in io.debezium.connector.common with parameters of type CdcSourceTaskContextModifierConstructorDescriptionDebeziumHeaderProducer(CdcSourceTaskContext sourceTaskContext) Constructs a new DebeziumHeaderProducer with the specified source task context. -
Uses of CdcSourceTaskContext in io.debezium.metrics
Constructors in io.debezium.metrics with parameters of type CdcSourceTaskContextModifierConstructorDescriptionprotectedMetrics(CdcSourceTaskContext taskContext, String contextName) protectedMetrics(CdcSourceTaskContext taskContext, Map<String, String> tags) -
Uses of CdcSourceTaskContext in io.debezium.pipeline
Fields in io.debezium.pipeline declared as CdcSourceTaskContextModifier and TypeFieldDescriptionprivate CdcSourceTaskContextChangeEventSourceCoordinator.taskContextMethods in io.debezium.pipeline with parameters of type CdcSourceTaskContextModifier and TypeMethodDescriptionprotected voidChangeEventSourceCoordinator.executeChangeEventSources(CdcSourceTaskContext taskContext, SnapshotChangeEventSource<P, O> snapshotSource, Offsets<P, O> previousOffsets, AtomicReference<LoggingContext.PreviousContext> previousLogContext, ChangeEventSource.ChangeEventSourceContext context) voidChangeEventSourceCoordinator.start(CdcSourceTaskContext taskContext, ChangeEventQueueMetrics changeEventQueueMetrics, EventMetadataProvider metadataProvider) -
Uses of CdcSourceTaskContext in io.debezium.pipeline.metrics
Fields in io.debezium.pipeline.metrics declared as CdcSourceTaskContextModifier and TypeFieldDescriptionprotected final CdcSourceTaskContextPipelineMetrics.taskContextMethods in io.debezium.pipeline.metrics with type parameters of type CdcSourceTaskContextModifier and TypeMethodDescription<T extends CdcSourceTaskContext>
SnapshotChangeEventSourceMetrics<P> DefaultChangeEventSourceMetricsFactory.getSnapshotMetrics(T taskContext, ChangeEventQueueMetrics changeEventQueueMetrics, EventMetadataProvider eventMetadataProvider) <T extends CdcSourceTaskContext>
StreamingChangeEventSourceMetrics<P> DefaultChangeEventSourceMetricsFactory.getStreamingMetrics(T taskContext, ChangeEventQueueMetrics changeEventQueueMetrics, EventMetadataProvider eventMetadataProvider, CapturedTablesSupplier capturedTablesSupplier) -
Uses of CdcSourceTaskContext in io.debezium.pipeline.metrics.spi
Methods in io.debezium.pipeline.metrics.spi with type parameters of type CdcSourceTaskContextModifier and TypeMethodDescription<T extends CdcSourceTaskContext>
SnapshotChangeEventSourceMetrics<P> ChangeEventSourceMetricsFactory.getSnapshotMetrics(T taskContext, ChangeEventQueueMetrics changeEventQueueMetrics, EventMetadataProvider eventMetadataProvider) Returns the snapshot change event source metrics.<T extends CdcSourceTaskContext>
StreamingChangeEventSourceMetrics<P> ChangeEventSourceMetricsFactory.getStreamingMetrics(T taskContext, ChangeEventQueueMetrics changeEventQueueMetrics, EventMetadataProvider eventMetadataProvider, CapturedTablesSupplier capturedTablesSupplier) Returns the streaming change event source metrics. -
Uses of CdcSourceTaskContext in io.debezium.relational
Fields in io.debezium.relational declared as CdcSourceTaskContextModifier and TypeFieldDescriptionprivate final CdcSourceTaskContext<? extends CommonConnectorConfig> RelationalDatabaseSchema.taskContextConstructors in io.debezium.relational with parameters of type CdcSourceTaskContextModifierConstructorDescriptionprotectedHistorizedRelationalDatabaseSchema(HistorizedRelationalDatabaseConnectorConfig config, io.debezium.spi.topic.TopicNamingStrategy<TableId> topicNamingStrategy, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, TableSchemaBuilder schemaBuilder, boolean tableIdCaseInsensitive, Key.KeyMapper customKeysMapper, CdcSourceTaskContext<? extends CommonConnectorConfig> taskContext) protectedRelationalDatabaseSchema(RelationalDatabaseConnectorConfig config, io.debezium.spi.topic.TopicNamingStrategy<TableId> topicNamingStrategy, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, TableSchemaBuilder schemaBuilder, boolean tableIdCaseInsensitive, Key.KeyMapper customKeysMapper, CdcSourceTaskContext<? extends CommonConnectorConfig> taskContext)