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

Class ByteBuddyUtils

java.lang.Object

org.apache.beam.sdk.schemas.utils.ByteBuddyUtils

@Internal
public class ByteBuddyUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ByteBuddyUtils.ConvertType	Give a Java type, returns the Java type expected for use with Row.
static class	ByteBuddyUtils.ConvertValueForGetter	Takes a StackManipulation that returns a value.
static class	ByteBuddyUtils.ConvertValueForSetter	Row is going to call the setter with its internal Java type, however the user object being set might have a different type internally.
static class	ByteBuddyUtils.DefaultTypeConversionsFactory
static class	ByteBuddyUtils.InjectPackageStrategy	A naming strategy for ByteBuddy classes.
static class	ByteBuddyUtils.TransformingMap<K1,V1,K2,V2>
static class	ByteBuddyUtils.TypeConversion<T>
static interface	ByteBuddyUtils.TypeConversionsFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final Schema.LogicalType<Instant,Row>	JAVA_INSTANT_LOGICAL_TYPE
static final Schema.LogicalType<LocalDate,Long>	JAVA_LOCAL_DATE_LOGICAL_TYPE
static final Schema.LogicalType<LocalDateTime,Row>	JAVA_LOCAL_DATE_TIME_LOGICAL_TYPE
static final Schema.LogicalType<LocalTime,Long>	JAVA_LOCAL_TIME_LOGICAL_TYPE
static final Schema.LogicalType<UUID,Row>	JAVA_UUID_LOGICAL_TYPE

Constructor Summary

Constructors

Constructor	Description
ByteBuddyUtils()

Method Summary

Modifier and Type	Method	Description
static <K1, V1, K2, V2> ByteBuddyUtils.TransformingMap<K1,V1,K2,V2>	getTransformingMap(Map<K1,V1> sourceMap, org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<K1,K2> keyFunction, org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<V1,V2> valueFunction)
static <ObjectT, ValueT> DynamicType.Builder<FieldValueGetter<@NonNull ObjectT,ValueT>>	subclassGetterInterface(ByteBuddy byteBuddy, Type objectType, Type fieldType)
static <ObjectT> DynamicType.Builder<FieldValueHaver<ObjectT>>	subclassHaverInterface(ByteBuddy byteBuddy, Class<?> objectType)
static <ObjectT, ValueT> DynamicType.Builder<FieldValueSetter<ObjectT,ValueT>>	subclassSetterInterface(ByteBuddy byteBuddy, Type objectType, Type fieldType)
static <FromT, DestT> Iterable<DestT>	transformContainer(Iterable<FromT> iterable, org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<FromT,DestT> function)

Methods inherited from class java.lang.Object

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

Field Details

JAVA_LOCAL_DATE_LOGICAL_TYPE

public static final Schema.LogicalType<LocalDate,Long> JAVA_LOCAL_DATE_LOGICAL_TYPE

JAVA_LOCAL_TIME_LOGICAL_TYPE

public static final Schema.LogicalType<LocalTime,Long> JAVA_LOCAL_TIME_LOGICAL_TYPE

JAVA_LOCAL_DATE_TIME_LOGICAL_TYPE

public static final Schema.LogicalType<LocalDateTime,Row> JAVA_LOCAL_DATE_TIME_LOGICAL_TYPE

JAVA_INSTANT_LOGICAL_TYPE

public static final Schema.LogicalType<Instant,Row> JAVA_INSTANT_LOGICAL_TYPE

JAVA_UUID_LOGICAL_TYPE

public static final Schema.LogicalType<UUID,Row> JAVA_UUID_LOGICAL_TYPE

Constructor Details

ByteBuddyUtils

public ByteBuddyUtils()

Method Details

subclassGetterInterface

public static <ObjectT,
ValueT>
DynamicType.Builder<FieldValueGetter<@NonNull ObjectT,ValueT>> subclassGetterInterface(ByteBuddy byteBuddy,
 Type objectType,
 Type fieldType)

subclassSetterInterface

public static <ObjectT,
ValueT>
DynamicType.Builder<FieldValueSetter<ObjectT,ValueT>> subclassSetterInterface(ByteBuddy byteBuddy,
 Type objectType,
 Type fieldType)

subclassHaverInterface

public static <ObjectT>
DynamicType.Builder<FieldValueHaver<ObjectT>> subclassHaverInterface(ByteBuddy byteBuddy,
 Class<?> objectType)

transformContainer

public static <FromT,
DestT> Iterable<DestT> transformContainer(Iterable<FromT> iterable,
 org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<FromT,DestT> function)

getTransformingMap

public static <K1,
V1,
K2,
V2>
ByteBuddyUtils.TransformingMap<K1,V1,K2,V2> getTransformingMap(Map<K1,V1> sourceMap,
 org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<K1,K2> keyFunction,
 org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<V1,V2> valueFunction)