Uses of Record Class
io.debezium.openlineage.ConnectorContext

Packages that use ConnectorContext

Package	Description
io.debezium.openlineage
io.debezium.openlineage.emitter

Uses of ConnectorContext in io.debezium.openlineage

Methods in io.debezium.openlineage that return ConnectorContext

Modifier and Type	Method	Description
static ConnectorContext	DebeziumOpenLineageEmitter.connectorContext(Map<String,String> config, String connectorName, UUID runId)
static ConnectorContext	ConnectorContext.from(Map<String,String> configuration, String connectorTypeName, UUID runId)	Creates a ConnectorContext instance from a configuration object and connector type name.
static ConnectorContext	ConnectorContext.from(org.apache.kafka.connect.header.Headers headers)	Creates a ConnectorContext instance from Kafka message headers.

Methods in io.debezium.openlineage with parameters of type ConnectorContext

Modifier and Type	Method	Description
static void	DebeziumOpenLineageEmitter.cleanup(ConnectorContext connectorContext)	Removes the emitter for the specified connector.
static void	DebeziumOpenLineageEmitter.emit(ConnectorContext connectorContext, io.debezium.connector.common.DebeziumTaskState state)	Emits a lineage event for the given source task state.
static void	DebeziumOpenLineageEmitter.emit(ConnectorContext connectorContext, io.debezium.connector.common.DebeziumTaskState state, Throwable t)	Emits a lineage event for the given source task state and exception.
static void	DebeziumOpenLineageEmitter.emit(ConnectorContext connectorContext, io.debezium.connector.common.DebeziumTaskState state, List<DatasetMetadata> datasetMetadata)	Emits a lineage inputDatasetMetadata for the given source task state and table inputDatasetMetadata.
static void	DebeziumOpenLineageEmitter.emit(ConnectorContext connectorContext, io.debezium.connector.common.DebeziumTaskState state, List<DatasetMetadata> datasetMetadata, Throwable t)	Emits a lineage event for the given source task state, table event, and exception.
private static LineageEmitter	DebeziumOpenLineageEmitter.getEmitter(ConnectorContext connectorContext)
private static LineageEmitter	DebeziumOpenLineageEmitter.init(ConnectorContext connectorContext)
private static boolean	DebeziumOpenLineageEmitter.isOpenLineageDisabled(ConnectorContext connectorContext)

Uses of ConnectorContext in io.debezium.openlineage.emitter

Methods in io.debezium.openlineage.emitter with parameters of type ConnectorContext

Modifier and Type	Method	Description
LineageEmitter	LineageEmitterFactory.get(ConnectorContext connectorContext)