org.apache.beam.sdk.schemas.utils

Class ConvertHelpers

java.lang.Object

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

public class ConvertHelpers
extends java.lang.Object

Helper functions for converting between equivalent schema types.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
ConvertHelpers()

Method Summary

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) 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 Detail

ConvertHelpers

public ConvertHelpers()

Method Detail

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)

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.