Package org.apache.beam.sdk.schemas.transforms

Class Cast<T>

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<PCollection<T>,PCollection<Row>>

org.apache.beam.sdk.schemas.transforms.Cast<T>

All Implemented Interfaces:

Serializable, HasDisplayData

public abstract class Cast<T>
extends PTransform<PCollection<T>,PCollection<Row>>

Set of utilities for casting rows between schemas.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Cast.CompatibilityError	Describes compatibility errors during casting.
static class	Cast.Narrowing	Narrowing changes type without guarantee to preserve data.
static interface	Cast.Validator	Interface for statically validating casts.
static class	Cast.Widening	Widening changes to type that can represent any possible value of the original type.

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

annotations, displayData, name, resourceHints

Constructor Summary

Constructors

Constructor	Description
Cast()

Method Summary

Modifier and Type	Method	Description
static Number	castNumber(Number value, Schema.TypeName input, Schema.TypeName output)
static Row	castRow(Row input, Schema inputSchema, Schema outputSchema)
static Object	castValue(Object inputValue, Schema.FieldType input, Schema.FieldType output)
PCollection<Row>	expand(PCollection<T> input)	Override this method to specify how this PTransform should be expanded on the given InputT.
static boolean	isDecimal(Schema.TypeName type)	Checks if type is decimal.
static boolean	isIntegral(Schema.TypeName type)	Checks if type is integral.
static <T> Cast<T>	narrowing(Schema outputSchema)
static <T> Cast<T>	of(Schema outputSchema, Cast.Validator validator)
abstract Schema	outputSchema()
abstract Cast.Validator	validator()
void	verifyCompatibility(Schema inputSchema)
static <T> Cast<T>	widening(Schema outputSchema)

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

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

Constructor Details

Cast

public Cast()

Method Details

outputSchema

public abstract Schema outputSchema()

validator

public abstract Cast.Validator validator()

of

public static <T> Cast<T> of(Schema outputSchema,
 Cast.Validator validator)

widening

public static <T> Cast<T> widening(Schema outputSchema)

narrowing

public static <T> Cast<T> narrowing(Schema outputSchema)

isIntegral

public static boolean isIntegral(Schema.TypeName type)

Checks if type is integral.

isDecimal

public static boolean isDecimal(Schema.TypeName type)

Checks if type is decimal.

verifyCompatibility

public void verifyCompatibility(Schema inputSchema)

expand

public PCollection<Row> expand(PCollection<T> input)

Description copied from class: PTransform

Override this method to specify how this PTransform should be expanded on the given InputT.

NOTE: This method should not be called directly. Instead apply the PTransform should be applied to the InputT using the apply method.

Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).

Specified by:

expand in class PTransform<PCollection<T>,PCollection<Row>>

castRow

public static Row castRow(Row input,
 Schema inputSchema,
 Schema outputSchema)

castNumber

public static Number castNumber(Number value,
 Schema.TypeName input,
 Schema.TypeName output)

castValue

public static Object castValue(Object inputValue,
 Schema.FieldType input,
 Schema.FieldType output)