org.apache.beam.sdk.schemas

Class GetterBasedSchemaProvider

java.lang.Object

org.apache.beam.sdk.schemas.GetterBasedSchemaProvider

All Implemented Interfaces:

java.io.Serializable, SchemaProvider

Direct Known Subclasses:

GetterBasedSchemaProviderV2

Deprecated.

new implementations should extend the GetterBasedSchemaProviderV2 class' methods which receive TypeDescriptors instead of ordinary Classes as arguments, which permits to support generic type signatures during schema inference

@Deprecated
public abstract class GetterBasedSchemaProvider
extends java.lang.Object
implements SchemaProvider

A SchemaProvider base class that vends schemas and rows based on FieldValueGetters.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GetterBasedSchemaProvider() Deprecated.

Method Summary

Modifier and Type	Method and Description
boolean	equals(@Nullable java.lang.Object obj) Deprecated.
abstract java.util.List<FieldValueGetter>	fieldValueGetters(java.lang.Class<?> targetClass, Schema schema) Deprecated. new implementations should override fieldValueGetters(TypeDescriptor, Schema) and make this method throw an UnsupportedOperationException
java.util.List<FieldValueGetter>	fieldValueGetters(TypeDescriptor<?> targetTypeDescriptor, Schema schema) Deprecated. Delegates to the fieldValueGetters(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.
abstract java.util.List<FieldValueTypeInformation>	fieldValueTypeInformations(java.lang.Class<?> targetClass, Schema schema) Deprecated. new implementations should override fieldValueTypeInformations(TypeDescriptor, Schema) and make this method throw an UnsupportedOperationException
java.util.List<FieldValueTypeInformation>	fieldValueTypeInformations(TypeDescriptor<?> targetTypeDescriptor, Schema schema) Deprecated. Delegates to the fieldValueTypeInformations(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.
<T> SerializableFunction<Row,T>	fromRowFunction(TypeDescriptor<T> typeDescriptor) Deprecated. Given a type, returns a function that converts from a Row object to that type.
int	hashCode() Deprecated.
abstract SchemaUserTypeCreator	schemaTypeCreator(java.lang.Class<?> targetClass, Schema schema) Deprecated. new implementations should override schemaTypeCreator(TypeDescriptor, Schema) and make this method throw an UnsupportedOperationException
SchemaUserTypeCreator	schemaTypeCreator(TypeDescriptor<?> targetTypeDescriptor, Schema schema) Deprecated. Delegates to the schemaTypeCreator(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.
<T> SerializableFunction<T,Row>	toRowFunction(TypeDescriptor<T> typeDescriptor) Deprecated. 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, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.sdk.schemas.SchemaProvider

schemaFor

Constructor Detail

GetterBasedSchemaProvider

public GetterBasedSchemaProvider()

Deprecated.

Method Detail

fieldValueGetters

@Deprecated
public abstract java.util.List<FieldValueGetter> fieldValueGetters(java.lang.Class<?> targetClass,
                                                                               Schema schema)

Deprecated. new implementations should override fieldValueGetters(TypeDescriptor, Schema) and make this method throw an UnsupportedOperationException

Implementing class should override to return FieldValueGetters.

fieldValueGetters

public java.util.List<FieldValueGetter> fieldValueGetters(TypeDescriptor<?> targetTypeDescriptor,
                                                          Schema schema)

Deprecated.

Delegates to the fieldValueGetters(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.

fieldValueTypeInformations

@Deprecated
public abstract java.util.List<FieldValueTypeInformation> fieldValueTypeInformations(java.lang.Class<?> targetClass,
                                                                                                 Schema schema)

Deprecated. new implementations should override fieldValueTypeInformations(TypeDescriptor, Schema) and make this method throw an UnsupportedOperationException

Implementing class should override to return a list of type-informations.

fieldValueTypeInformations

public java.util.List<FieldValueTypeInformation> fieldValueTypeInformations(TypeDescriptor<?> targetTypeDescriptor,
                                                                            Schema schema)

Deprecated.

Delegates to the fieldValueTypeInformations(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.

schemaTypeCreator

@Deprecated
public abstract SchemaUserTypeCreator schemaTypeCreator(java.lang.Class<?> targetClass,
                                                                    Schema schema)

Deprecated. new implementations should override schemaTypeCreator(TypeDescriptor, Schema) and make this method throw an UnsupportedOperationException

Implementing class should override to return a constructor.

schemaTypeCreator

public SchemaUserTypeCreator schemaTypeCreator(TypeDescriptor<?> targetTypeDescriptor,
                                               Schema schema)

Deprecated.

Delegates to the schemaTypeCreator(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.

toRowFunction

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

Deprecated.

Description copied from interface: SchemaProvider

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)

Deprecated.

Description copied from interface: SchemaProvider

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

hashCode

public int hashCode()

Deprecated.

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(@Nullable java.lang.Object obj)

Deprecated.

Overrides:

equals in class java.lang.Object