org.apache.beam.sdk.schemas

Class SchemaUtils

java.lang.Object

org.apache.beam.sdk.schemas.SchemaUtils

public class SchemaUtils
extends java.lang.Object

A set of utility functions for schemas.

Constructor Summary

Constructors

Constructor and Description
SchemaUtils()

Method Summary

Modifier and Type	Method and Description
static Schema	mergeWideningNullable(Schema schema1, Schema schema2) Given two schema that have matching types, return a nullable-widened schema.

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaUtils

public SchemaUtils()

Method Detail

mergeWideningNullable

public static Schema mergeWideningNullable(Schema schema1,
                                           Schema schema2)

Given two schema that have matching types, return a nullable-widened schema.

The schemas must have matching types, except for field names which can differ. The returned schema will contain the field names in the first schema. All field types will be nullable if the corresponding field type is nullable in either of the input schemas.