Package org.apache.beam.sdk.schemas.utils

Class ConvertHelpers

java.lang.Object

org.apache.beam.sdk.schemas.utils.ConvertHelpers

public class ConvertHelpers
extends Object

Helper functions for converting between equivalent schema types.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConvertHelpers.ConvertedSchemaInformation<T>	Return value after converting a schema.

Constructor Summary

Constructors

Constructor	Description
ConvertHelpers()

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

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

Constructor Details

ConvertHelpers

public ConvertHelpers()

Method Details

getConvertedSchemaInformation

public 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.

getConvertPrimitive

public static <OutputT>
SerializableFunction<?,OutputT> getConvertPrimitive(Schema.FieldType fieldType,
 TypeDescriptor<?> outputTypeDescriptor,
 ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

Returns a function to convert a Row into a primitive type. This only works when the row schema contains a single field, and that field is convertible to the primitive type.