Package org.apache.beam.sdk.schemas.annotations

Class DefaultSchema.DefaultSchemaProvider

java.lang.Object

org.apache.beam.sdk.schemas.annotations.DefaultSchema.DefaultSchemaProvider

All Implemented Interfaces:

Serializable, SchemaProvider

Enclosing class:

DefaultSchema

public static class DefaultSchema.DefaultSchemaProvider
extends Object
implements SchemaProvider

SchemaProvider for default schemas. Looks up the provider annotated for a type, and delegates to that provider.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DefaultSchemaProvider()

Method Summary

Modifier and Type	Method	Description
<T> SerializableFunction<Row,T>	fromRowFunction(TypeDescriptor<T> typeDescriptor)	Given a type, returns a function that converts from a Row object to that type.
<T> @Nullable SchemaProvider	getUnderlyingSchemaProvider(Class<T> clazz)	Retrieves the underlying SchemaProvider for the given Class.
<T> @Nullable SchemaProvider	getUnderlyingSchemaProvider(TypeDescriptor<T> typeDescriptor)	Retrieves the underlying SchemaProvider for the given TypeDescriptor.
<T> Schema	schemaFor(TypeDescriptor<T> typeDescriptor)	Lookup a schema for the given type.
<T> SerializableFunction<T,Row>	toRowFunction(TypeDescriptor<T> typeDescriptor)	Given a type, return a function that converts that type to a Row object If no schema exists, returns null.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultSchemaProvider

public DefaultSchemaProvider()

Method Details

getUnderlyingSchemaProvider

public <T> @Nullable SchemaProvider getUnderlyingSchemaProvider(TypeDescriptor<T> typeDescriptor)

Retrieves the underlying SchemaProvider for the given TypeDescriptor. If no provider is found, returns null.

getUnderlyingSchemaProvider

public <T> @Nullable SchemaProvider getUnderlyingSchemaProvider(Class<T> clazz)

Retrieves the underlying SchemaProvider for the given Class. If no provider is found, returns null.

schemaFor

public <T> Schema schemaFor(TypeDescriptor<T> typeDescriptor)

Description copied from interface: SchemaProvider

Lookup a schema for the given type. If no schema exists, returns null.

Specified by:

schemaFor in interface SchemaProvider

toRowFunction

public <T> SerializableFunction<T,Row> toRowFunction(TypeDescriptor<T> typeDescriptor)

Given a type, return a function that converts that type to a Row object If no schema exists, returns null.

Specified by:

toRowFunction in interface SchemaProvider

fromRowFunction

public <T> SerializableFunction<Row,T> fromRowFunction(TypeDescriptor<T> typeDescriptor)

Given a type, returns a function that converts from a Row object to that type. If no schema exists, returns null.

Specified by:

fromRowFunction in interface SchemaProvider