Index

B C D E F G H I K L M N O R S T V
All Classes and Interfaces|All Packages|Constant Field Values

B

buildFieldDefinition(Field) - Method in class io.debezium.openlineage.dataset.DatasetDataExtractor

C

cleanup(ConnectorContext) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

Removes the emitter for the specified connector.

close() - Method in interface io.debezium.openlineage.emitter.LineageEmitter

close() - Method in class io.debezium.openlineage.emitter.NoOpLineageEmitter

config - Variable in record class io.debezium.openlineage.ConnectorContext

The field for the config record component.

config() - Method in record class io.debezium.openlineage.ConnectorContext

Returns the value of the config record component.

connectorContext(Map<String, String>, String, UUID) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

ConnectorContext - Record Class in io.debezium.openlineage

Represents the context information for a Kafka Connect connector, containing essential metadata required for connector operations and identification.

ConnectorContext(String, String, String, String, UUID, Map<String, String>) - Constructor for record class io.debezium.openlineage.ConnectorContext

Creates an instance of a ConnectorContext record class.

connectorLogicalName - Variable in record class io.debezium.openlineage.ConnectorContext

The field for the connectorLogicalName record component.

connectorLogicalName() - Method in record class io.debezium.openlineage.ConnectorContext

Returns the value of the connectorLogicalName record component.

connectorName - Variable in record class io.debezium.openlineage.ConnectorContext

The field for the connectorName record component.

connectorName() - Method in record class io.debezium.openlineage.ConnectorContext

Returns the value of the connectorName record component.

D

DATABASE - Enum constant in enum class io.debezium.openlineage.dataset.DatasetMetadata.DataStore

DatasetDataExtractor - Class in io.debezium.openlineage.dataset

DatasetDataExtractor() - Constructor for class io.debezium.openlineage.dataset.DatasetDataExtractor

DatasetKind() - Constructor for enum class io.debezium.openlineage.dataset.DatasetMetadata.DatasetKind

DatasetMetadata - Record Class in io.debezium.openlineage.dataset

Represents metadata for a dataset, including its name, kind, type, and field definitions.

DatasetMetadata(String, DatasetMetadata.DatasetKind, String, DatasetMetadata.DataStore, List<DatasetMetadata.FieldDefinition>) - Constructor for record class io.debezium.openlineage.dataset.DatasetMetadata

Creates an instance of a DatasetMetadata record class.

DatasetMetadata.DatasetKind - Enum Class in io.debezium.openlineage.dataset

Enumeration representing the kind of dataset.

DatasetMetadata.DataStore - Enum Class in io.debezium.openlineage.dataset

Enumeration representing the final data store related to the dataset.

DatasetMetadata.FieldDefinition - Record Class in io.debezium.openlineage.dataset

Represents the definition of a field within a dataset.

DataStore() - Constructor for enum class io.debezium.openlineage.dataset.DatasetMetadata.DataStore

DebeziumOpenLineageEmitter - Class in io.debezium.openlineage

A utility class for emitting OpenLineage events from Debezium connectors.

DebeziumOpenLineageEmitter() - Constructor for class io.debezium.openlineage.DebeziumOpenLineageEmitter

description - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

The field for the description record component.

description() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Returns the value of the description record component.

E

emit(DebeziumTaskState) - Method in interface io.debezium.openlineage.emitter.LineageEmitter

emit(DebeziumTaskState) - Method in class io.debezium.openlineage.emitter.NoOpLineageEmitter

emit(DebeziumTaskState, Throwable) - Method in interface io.debezium.openlineage.emitter.LineageEmitter

emit(DebeziumTaskState, Throwable) - Method in class io.debezium.openlineage.emitter.NoOpLineageEmitter

emit(DebeziumTaskState, List<DatasetMetadata>) - Method in interface io.debezium.openlineage.emitter.LineageEmitter

emit(DebeziumTaskState, List<DatasetMetadata>) - Method in class io.debezium.openlineage.emitter.NoOpLineageEmitter

emit(DebeziumTaskState, List<DatasetMetadata>, Throwable) - Method in interface io.debezium.openlineage.emitter.LineageEmitter

emit(DebeziumTaskState, List<DatasetMetadata>, Throwable) - Method in class io.debezium.openlineage.emitter.NoOpLineageEmitter

emit(ConnectorContext, DebeziumTaskState) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

Emits a lineage event for the given source task state.

emit(ConnectorContext, DebeziumTaskState, Throwable) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

Emits a lineage event for the given source task state and exception.

emit(ConnectorContext, DebeziumTaskState, List<DatasetMetadata>) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

Emits a lineage inputDatasetMetadata for the given source task state and table inputDatasetMetadata.

emit(ConnectorContext, DebeziumTaskState, List<DatasetMetadata>, Throwable) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

Emits a lineage event for the given source task state, table event, and exception.

emitters - Static variable in class io.debezium.openlineage.DebeziumOpenLineageEmitter

equals(Object) - Method in record class io.debezium.openlineage.ConnectorContext

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class io.debezium.openlineage.dataset.DatasetMetadata

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Indicates whether some other object is "equal to" this one.

extract(ConnectRecord<R>) - Method in class io.debezium.openlineage.dataset.DatasetDataExtractor

F

FieldDefinition(String, String, String) - Constructor for record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Convenience constructor for creating a simple field definition without nested fields.

FieldDefinition(String, String, String, List<DatasetMetadata.FieldDefinition>) - Constructor for record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Creates an instance of a FieldDefinition record class.

fields - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

The field for the fields record component.

fields - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata

The field for the fields record component.

fields() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Returns the value of the fields record component.

fields() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata

Returns the value of the fields record component.

from(Map<String, String>, String, UUID) - Static method in record class io.debezium.openlineage.ConnectorContext

Creates a ConnectorContext instance from a configuration object and connector type name.

from(Headers) - Static method in record class io.debezium.openlineage.ConnectorContext

Creates a ConnectorContext instance from Kafka message headers.

G

get(ConnectorContext) - Method in interface io.debezium.openlineage.emitter.LineageEmitterFactory

getEmitter(ConnectorContext) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

getNoOpLineageEmitter() - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

H

hashCode() - Method in record class io.debezium.openlineage.ConnectorContext

Returns a hash code value for this object.

hashCode() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Returns a hash code value for this object.

hashCode() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata

Returns a hash code value for this object.

I

INFO - Static variable in class io.debezium.openlineage.Module

init(ConnectorContext) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

INPUT - Enum constant in enum class io.debezium.openlineage.dataset.DatasetMetadata.DatasetKind

Represents a dataset that serves as an input source

io.debezium.openlineage - package io.debezium.openlineage

io.debezium.openlineage.dataset - package io.debezium.openlineage.dataset

io.debezium.openlineage.emitter - package io.debezium.openlineage.emitter

isOpenLineageDisabled(ConnectorContext) - Static method in class io.debezium.openlineage.DebeziumOpenLineageEmitter

K

KAFKA - Enum constant in enum class io.debezium.openlineage.dataset.DatasetMetadata.DataStore

KEY_FORMAT - Static variable in record class io.debezium.openlineage.ConnectorContext

kind - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata

The field for the kind record component.

kind() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata

Returns the value of the kind record component.

L

LineageEmitter - Interface in io.debezium.openlineage.emitter

lineageEmitterFactory - Static variable in class io.debezium.openlineage.DebeziumOpenLineageEmitter

LineageEmitterFactory - Interface in io.debezium.openlineage.emitter

LOGGER - Static variable in record class io.debezium.openlineage.ConnectorContext

LOGGER - Static variable in class io.debezium.openlineage.DebeziumOpenLineageEmitter

LOGGER - Static variable in class io.debezium.openlineage.emitter.NoOpLineageEmitter

M

Module - Class in io.debezium.openlineage

Module() - Constructor for class io.debezium.openlineage.Module

N

name - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

The field for the name record component.

name - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata

The field for the name record component.

name() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Returns the value of the name record component.

name() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata

Returns the value of the name record component.

noOpLineageEmitter - Static variable in class io.debezium.openlineage.DebeziumOpenLineageEmitter

NoOpLineageEmitter - Class in io.debezium.openlineage.emitter

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

NoOpLineageEmitter() - Constructor for class io.debezium.openlineage.emitter.NoOpLineageEmitter

O

OPEN_LINEAGE_INTEGRATION_CONFIG_FILE_PATH - Static variable in class io.debezium.openlineage.OpenLineageConfig

OPEN_LINEAGE_INTEGRATION_DATASET_KAFKA_BOOTSTRAP_SERVER - Static variable in class io.debezium.openlineage.OpenLineageConfig

OPEN_LINEAGE_INTEGRATION_ENABLED - Static variable in class io.debezium.openlineage.OpenLineageConfig

OPEN_LINEAGE_INTEGRATION_JOB_DESCRIPTION - Static variable in class io.debezium.openlineage.OpenLineageConfig

OPEN_LINEAGE_INTEGRATION_JOB_NAMESPACE - Static variable in class io.debezium.openlineage.OpenLineageConfig

OPEN_LINEAGE_INTEGRATION_JOB_OWNERS - Static variable in class io.debezium.openlineage.OpenLineageConfig

OPEN_LINEAGE_INTEGRATION_JOB_TAGS - Static variable in class io.debezium.openlineage.OpenLineageConfig

OpenLineageConfig - Class in io.debezium.openlineage

Configuration fields for OpenLineage integration with Debezium.

OpenLineageConfig() - Constructor for class io.debezium.openlineage.OpenLineageConfig

OUTPUT - Enum constant in enum class io.debezium.openlineage.dataset.DatasetMetadata.DatasetKind

Represents a dataset that serves as an output destination

R

runId - Variable in record class io.debezium.openlineage.ConnectorContext

The field for the runId record component.

runId() - Method in record class io.debezium.openlineage.ConnectorContext

Returns the value of the runId record component.

S

SERVICE_LOADER_LOCK - Static variable in class io.debezium.openlineage.DebeziumOpenLineageEmitter

store - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata

The field for the store record component.

store() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata

Returns the value of the store record component.

STREAM_DATASET_TYPE - Static variable in record class io.debezium.openlineage.dataset.DatasetMetadata

T

TABLE_DATASET_TYPE - Static variable in record class io.debezium.openlineage.dataset.DatasetMetadata

taskId - Variable in record class io.debezium.openlineage.ConnectorContext

The field for the taskId record component.

taskId() - Method in record class io.debezium.openlineage.ConnectorContext

Returns the value of the taskId record component.

toEmitterKey() - Method in record class io.debezium.openlineage.ConnectorContext

Generates a unique emitter key for this connector context.

toString() - Method in record class io.debezium.openlineage.ConnectorContext

Returns a string representation of this record class.

toString() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Returns a string representation of this record class.

toString() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata

Returns a string representation of this record class.

type - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata

The field for the type record component.

type() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata

Returns the value of the type record component.

typeName - Variable in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

The field for the typeName record component.

typeName() - Method in record class io.debezium.openlineage.dataset.DatasetMetadata.FieldDefinition

Returns the value of the typeName record component.

V

valueOf(String) - Static method in enum class io.debezium.openlineage.dataset.DatasetMetadata.DatasetKind

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.debezium.openlineage.dataset.DatasetMetadata.DataStore

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.debezium.openlineage.dataset.DatasetMetadata.DatasetKind

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.debezium.openlineage.dataset.DatasetMetadata.DataStore

Returns an array containing the constants of this enum class, in the order they are declared.

version - Variable in record class io.debezium.openlineage.ConnectorContext

The field for the version record component.

version() - Method in record class io.debezium.openlineage.ConnectorContext

Returns the value of the version record component.

version() - Static method in class io.debezium.openlineage.Module

B C D E F G H I K L M N O R S T V
All Classes and Interfaces|All Packages|Constant Field Values