org.apache.beam.sdk.schemas.transforms

Class AddFields

java.lang.Object

org.apache.beam.sdk.schemas.transforms.AddFields

public class AddFields
extends java.lang.Object

A transform to add new nullable fields to a PCollection's schema. Elements are extended to have the new schema. By default new fields are nullable, and input rows will be extended to the new schema by inserting null values. However explicit default values for new fields can be set using AddFields.Inner.field(String, Schema.FieldType, Object). Nested fields can be added as well.

Example use:

 PCollection<Event> events = readEvents();
 PCollection<Row> augmentedEvents =
   events.apply(AddFields.<Event>create()
       .field("userId", FieldType.STRING)
       .field("location.zipcode", FieldType.INT32)
       .field("userDetails.isSpecialUser", "FieldType.BOOLEAN", false));
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AddFields.Inner<T> Inner PTransform for AddFields.

Constructor Summary

Constructors

Constructor and Description
AddFields()

Method Summary

Modifier and Type	Method and Description
static <T> AddFields.Inner<T>	create()

Methods inherited from class java.lang.Object

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

Constructor Detail

AddFields

public AddFields()

Method Detail

create

public static <T> AddFields.Inner<T> create()