Package io.debezium.openlineage.emitter

Class NoOpLineageEmitter

java.lang.Object

io.debezium.openlineage.emitter.NoOpLineageEmitter

All Implemented Interfaces:

LineageEmitter

public class NoOpLineageEmitter
extends Object
implements LineageEmitter

A no-operation implementation of LineageEmitter that performs no actual lineage emission.

This implementation is used as a default when lineage emission is disabled. It logs debug messages for all emit operations but does not perform any actual lineage tracking or data emission. Users who want to enable actual lineage emission should set the configuration property openlineage.integration.enabled=true.

All emit methods in this class are effectively no-ops that only log the operations at debug level.

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
NoOpLineageEmitter()

Method Summary

Modifier and Type	Method	Description
void	close()
void	emit(io.debezium.connector.common.DebeziumTaskState state)
void	emit(io.debezium.connector.common.DebeziumTaskState state, Throwable t)
void	emit(io.debezium.connector.common.DebeziumTaskState state, List<DatasetMetadata> datasetMetadata)
void	emit(io.debezium.connector.common.DebeziumTaskState state, List<DatasetMetadata> datasetMetadata, Throwable t)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

Constructor Details

NoOpLineageEmitter

public NoOpLineageEmitter()

Method Details

emit

public void emit(io.debezium.connector.common.DebeziumTaskState state)

Specified by:

emit in interface LineageEmitter

emit

public void emit(io.debezium.connector.common.DebeziumTaskState state,
 Throwable t)

Specified by:

emit in interface LineageEmitter

emit

public void emit(io.debezium.connector.common.DebeziumTaskState state,
 List<DatasetMetadata> datasetMetadata)

Specified by:

emit in interface LineageEmitter

emit

public void emit(io.debezium.connector.common.DebeziumTaskState state,
 List<DatasetMetadata> datasetMetadata,
 Throwable t)

Specified by:

emit in interface LineageEmitter

close

public void close()

Specified by:

close in interface LineageEmitter