public class SchemaProjector extends Object
SchemaProjector is utility to project a value between compatible schemas and throw exceptions when non compatible schemas are provided.
Constructor and Description |
---|
SchemaProjector() |
Modifier and Type | Method and Description |
---|---|
static Object |
project(Schema source,
Object record,
Schema target)
This method project a value between compatible schemas and throw exceptions when non compatible schemas are provided
|
public static Object project(Schema source, Object record, Schema target) throws SchemaProjectorException
source
- the schema used to construct the recordrecord
- the value to project from source schema to target schematarget
- the schema to project the record toSchemaProjectorException
- if the target schema is not optional and does not have a default value