Package org.apache.kafka.connect.data

Class SchemaProjector

java.lang.Object

org.apache.kafka.connect.data.SchemaProjector

public class SchemaProjector
extends java.lang.Object

SchemaProjector is utility to project a value between compatible schemas and throw exceptions when non compatible schemas are provided.

Constructor Summary

Constructors

Constructor	Description
SchemaProjector()

Method Summary

Modifier and Type	Method	Description
static java.lang.Object	project(Schema source, java.lang.Object record, Schema target)	This method project a value between compatible schemas and throw exceptions when non compatible schemas are provided

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaProjector

public SchemaProjector()

Method Detail

project

public static java.lang.Object project(Schema source,
                                       java.lang.Object record,
                                       Schema target)
                                throws SchemaProjectorException

This method project a value between compatible schemas and throw exceptions when non compatible schemas are provided

Parameters:

source - the schema used to construct the record

record - the value to project from source schema to target schema

target - the schema to project the record to

Returns:

the projected value with target schema

Throws:

SchemaProjectorException