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:

java.io.Serializable, HasDisplayData

@Experimental(value=SCHEMAS)
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 and 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

name

Constructor Summary

Constructors

Constructor and Description
Cast()

Method Summary

Modifier and Type	Method and Description
static java.lang.Number	castNumber(java.lang.Number value, Schema.TypeName input, Schema.TypeName output)
static Row	castRow(Row input, Schema inputSchema, Schema outputSchema)
static java.lang.Object	castValue(java.lang.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

compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString, validate

Methods inherited from class java.lang.Object

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

Constructor Detail

Cast

public Cast()

Method Detail

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 java.lang.Number castNumber(java.lang.Number value,
                                          Schema.TypeName input,
                                          Schema.TypeName output)

castValue

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