Package io.debezium.openlineage.dataset

Class DatasetDataExtractor

java.lang.Object

io.debezium.openlineage.dataset.DatasetDataExtractor

public class DatasetDataExtractor
extends Object

Constructor Summary

Constructors

Constructor	Description
DatasetDataExtractor()

Method Summary

Modifier and Type	Method	Description
private DatasetMetadata.FieldDefinition	buildFieldDefinition(org.apache.kafka.connect.data.Field field)
<R extends org.apache.kafka.connect.connector.ConnectRecord<R>> List<DatasetMetadata.FieldDefinition>	extract(org.apache.kafka.connect.connector.ConnectRecord<R> record)

Methods inherited from class java.lang.Object

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

Constructor Details

DatasetDataExtractor

public DatasetDataExtractor()

Method Details

extract

public <R extends org.apache.kafka.connect.connector.ConnectRecord<R>>
List<DatasetMetadata.FieldDefinition> extract(org.apache.kafka.connect.connector.ConnectRecord<R> record)

buildFieldDefinition

private DatasetMetadata.FieldDefinition buildFieldDefinition(org.apache.kafka.connect.data.Field field)