org.apache.beam.sdk.schemas.utils

Class JavaBeanUtils

java.lang.Object

org.apache.beam.sdk.schemas.utils.JavaBeanUtils

public class JavaBeanUtils
extends java.lang.Object

A set of utilities to generate getter and setter classes for JavaBean objects.

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.Map<ReflectUtils.TypeDescriptorWithSchema<?>,SchemaUserTypeCreator>	CACHED_CREATORS
static java.lang.String	GETTER_WITH_NULL_METHOD_ERROR
static java.lang.String	SETTER_WITH_NULL_METHOD_ERROR

Constructor Summary

Constructors

Constructor and Description
JavaBeanUtils()

Method Summary

Modifier and Type	Method and Description
static <T,K extends java.lang.Comparable<? super K>> java.util.Comparator<T>	comparingNullFirst(java.util.function.Function<? super T,? extends K> keyExtractor)
static <T> SchemaUserTypeCreator	createConstructorCreator(java.lang.Class<T> clazz, java.lang.reflect.Constructor<T> constructor, Schema schema, java.util.List<FieldValueTypeInformation> types, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)
static <ObjectT,ValueT> FieldValueGetter<ObjectT,ValueT>	createGetter(FieldValueTypeInformation typeInformation, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)
static <ObjectT,ValueT> FieldValueSetter<ObjectT,ValueT>	createSetter(FieldValueTypeInformation typeInformation, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)
static <T> SchemaUserTypeCreator	createStaticCreator(java.lang.Class<T> clazz, java.lang.reflect.Method creator, Schema schema, java.util.List<FieldValueTypeInformation> types, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)
static SchemaUserTypeCreator	getConstructorCreator(TypeDescriptor<?> typeDescriptor, java.lang.reflect.Constructor constructor, Schema schema, FieldValueTypeSupplier fieldValueTypeSupplier, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)
static java.util.List<FieldValueTypeInformation>	getFieldTypes(TypeDescriptor<?> typeDescriptor, Schema schema, FieldValueTypeSupplier fieldValueTypeSupplier)
static <T> java.util.List<FieldValueGetter<T,java.lang.Object>>	getGetters(TypeDescriptor<T> typeDescriptor, Schema schema, FieldValueTypeSupplier fieldValueTypeSupplier, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory) Return the list of FieldValueGetters for a Java Bean class
static java.util.List<FieldValueSetter>	getSetters(TypeDescriptor<?> typeDescriptor, Schema schema, FieldValueTypeSupplier fieldValueTypeSupplier, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory) Return the list of FieldValueSetters for a Java Bean class
static SchemaUserTypeCreator	getStaticCreator(TypeDescriptor<?> typeDescriptor, java.lang.reflect.Method creator, Schema schema, FieldValueTypeSupplier fieldValueTypeSupplier, ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)
static Schema	schemaFromJavaBeanClass(TypeDescriptor<?> typeDescriptor, FieldValueTypeSupplier fieldValueTypeSupplier) Create a Schema for a Java Bean class.
static void	validateJavaBean(java.util.List<FieldValueTypeInformation> getters, java.util.List<FieldValueTypeInformation> setters, Schema schema)

Methods inherited from class java.lang.Object

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

Field Detail

GETTER_WITH_NULL_METHOD_ERROR

public static final java.lang.String GETTER_WITH_NULL_METHOD_ERROR

SETTER_WITH_NULL_METHOD_ERROR

public static final java.lang.String SETTER_WITH_NULL_METHOD_ERROR

CACHED_CREATORS

public static final java.util.Map<ReflectUtils.TypeDescriptorWithSchema<?>,SchemaUserTypeCreator> CACHED_CREATORS

Constructor Detail

JavaBeanUtils

public JavaBeanUtils()

Method Detail

schemaFromJavaBeanClass

public static Schema schemaFromJavaBeanClass(TypeDescriptor<?> typeDescriptor,
                                             FieldValueTypeSupplier fieldValueTypeSupplier)

Create a Schema for a Java Bean class.

validateJavaBean

public static void validateJavaBean(java.util.List<FieldValueTypeInformation> getters,
                                    java.util.List<FieldValueTypeInformation> setters,
                                    Schema schema)

getFieldTypes

public static java.util.List<FieldValueTypeInformation> getFieldTypes(TypeDescriptor<?> typeDescriptor,
                                                                      Schema schema,
                                                                      FieldValueTypeSupplier fieldValueTypeSupplier)

getGetters

public static <T> java.util.List<FieldValueGetter<T,java.lang.Object>> getGetters(TypeDescriptor<T> typeDescriptor,
                                                                                  Schema schema,
                                                                                  FieldValueTypeSupplier fieldValueTypeSupplier,
                                                                                  ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

Return the list of FieldValueGetters for a Java Bean class

The returned list is ordered by the order of fields in the schema.

createGetter

public static <ObjectT,ValueT> FieldValueGetter<ObjectT,ValueT> createGetter(FieldValueTypeInformation typeInformation,
                                                                             ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

getSetters

public static java.util.List<FieldValueSetter> getSetters(TypeDescriptor<?> typeDescriptor,
                                                          Schema schema,
                                                          FieldValueTypeSupplier fieldValueTypeSupplier,
                                                          ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

Return the list of FieldValueSetters for a Java Bean class

The returned list is ordered by the order of fields in the schema.

createSetter

public static <ObjectT,ValueT> FieldValueSetter<ObjectT,ValueT> createSetter(FieldValueTypeInformation typeInformation,
                                                                             ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

getConstructorCreator

public static SchemaUserTypeCreator getConstructorCreator(TypeDescriptor<?> typeDescriptor,
                                                          java.lang.reflect.Constructor constructor,
                                                          Schema schema,
                                                          FieldValueTypeSupplier fieldValueTypeSupplier,
                                                          ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

createConstructorCreator

public static <T> SchemaUserTypeCreator createConstructorCreator(java.lang.Class<T> clazz,
                                                                 java.lang.reflect.Constructor<T> constructor,
                                                                 Schema schema,
                                                                 java.util.List<FieldValueTypeInformation> types,
                                                                 ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

getStaticCreator

public static SchemaUserTypeCreator getStaticCreator(TypeDescriptor<?> typeDescriptor,
                                                     java.lang.reflect.Method creator,
                                                     Schema schema,
                                                     FieldValueTypeSupplier fieldValueTypeSupplier,
                                                     ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

createStaticCreator

public static <T> SchemaUserTypeCreator createStaticCreator(java.lang.Class<T> clazz,
                                                            java.lang.reflect.Method creator,
                                                            Schema schema,
                                                            java.util.List<FieldValueTypeInformation> types,
                                                            ByteBuddyUtils.TypeConversionsFactory typeConversionsFactory)

comparingNullFirst

public static <T,K extends java.lang.Comparable<? super K>> java.util.Comparator<T> comparingNullFirst(java.util.function.Function<? super T,? extends K> keyExtractor)