@Experimental(value=SCHEMAS) public class ConvertHelpers extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
ConvertHelpers.ConvertedSchemaInformation<T>
Return value after converting a schema.
|
Constructor and Description |
---|
ConvertHelpers() |
Modifier and Type | Method and Description |
---|---|
static <T> ConvertHelpers.ConvertedSchemaInformation<T> |
getConvertedSchemaInformation(Schema inputSchema,
TypeDescriptor<T> outputType,
SchemaRegistry schemaRegistry)
Get the coder used for converting from an inputSchema to a given type.
|
static <OutputT> SerializableFunction<?,OutputT> |
getConvertPrimitive(Schema.FieldType fieldType,
TypeDescriptor<?> outputTypeDescriptor,
ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)
Returns a function to convert a Row into a primitive type.
|
public static <T> ConvertHelpers.ConvertedSchemaInformation<T> getConvertedSchemaInformation(Schema inputSchema, TypeDescriptor<T> outputType, SchemaRegistry schemaRegistry)
public static <OutputT> SerializableFunction<?,OutputT> getConvertPrimitive(Schema.FieldType fieldType, TypeDescriptor<?> outputTypeDescriptor, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)