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

Class AddFields

java.lang.Object

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

public class AddFields
extends 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	Description
static class	AddFields.Inner<T>	Inner PTransform for AddFields.

Constructor Summary

Constructors

Constructor	Description
AddFields()

Method Summary

Modifier and Type	Method	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 Details

AddFields

public AddFields()

Method Details

create

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