org.apache.beam.sdk.schemas.utils

Class StaticSchemaInference

java.lang.Object

org.apache.beam.sdk.schemas.utils.StaticSchemaInference

public class StaticSchemaInference
extends java.lang.Object

A set of utilities for inferring a Beam Schema from static Java types.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StaticSchemaInference.TypeInformation Relevant information about a Java type.

Constructor Summary

Constructors

Constructor and Description
StaticSchemaInference()

Method Summary

Modifier and Type	Method and Description
static Schema	schemaFromClass(java.lang.Class<?> clazz, java.util.function.Function<java.lang.Class,java.util.List<StaticSchemaInference.TypeInformation>> getTypesForClass) Infer a schema from a Java class.

Methods inherited from class java.lang.Object

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

Constructor Detail

StaticSchemaInference

public StaticSchemaInference()

Method Detail

schemaFromClass

public static Schema schemaFromClass(java.lang.Class<?> clazz,
                                     java.util.function.Function<java.lang.Class,java.util.List<StaticSchemaInference.TypeInformation>> getTypesForClass)

Infer a schema from a Java class.

Takes in a function to extract a list of field types from a class. Different callers may have different strategies for extracting this list: e.g. introspecting public member variables, public getter methods, or special annotations on the class.