org.apache.beam.io.debezium

Interface SourceRecordMapper<T>

Type Parameters:

T - The desired type you want to map the Kafka source record

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

SourceRecordJson.SourceRecordJsonMapper

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface SourceRecordMapper<T>
extends java.io.Serializable

Interface used to map a Kafka source record.

Method Summary

Modifier and Type	Method and Description
T	mapSourceRecord(org.apache.kafka.connect.source.SourceRecord sourceRecord)

Method Detail

mapSourceRecord

T mapSourceRecord(org.apache.kafka.connect.source.SourceRecord sourceRecord)
           throws java.lang.Exception

Throws:

java.lang.Exception