File tree Expand file tree Collapse file tree
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms Expand file tree Collapse file tree Original file line number Diff line number Diff line change 3333import org .apache .beam .sdk .values .Row ;
3434import org .apache .beam .sdk .values .TypeDescriptor ;
3535import org .apache .beam .vendor .guava .v32_1_2_jre .com .google .common .collect .ImmutableList ;
36+ import org .checkerframework .dataflow .qual .Pure ;
3637
3738/** Represents information about how a DoFn extracts schemas. */
3839@ AutoValue
@@ -46,12 +47,15 @@ public abstract class DoFnSchemaInformation implements Serializable {
4647 * The schema of the @Element parameter. If the Java type does not match the input PCollection but
4748 * the schemas are compatible, Beam will automatically convert between the Java types.
4849 */
50+ @ Pure
4951 public abstract List <SerializableFunction <?, ?>> getElementConverters ();
5052
5153 /** Effective FieldAccessDescriptor applied by DoFn. */
54+ @ Pure
5255 public abstract FieldAccessDescriptor getFieldAccessDescriptor ();
5356
5457 /** Create an instance. */
58+ @ Pure
5559 public static DoFnSchemaInformation create () {
5660 return new AutoValue_DoFnSchemaInformation .Builder ()
5761 .setElementConverters (Collections .emptyList ())
@@ -66,9 +70,11 @@ public abstract static class Builder {
6670
6771 abstract Builder setFieldAccessDescriptor (FieldAccessDescriptor descriptor );
6872
73+ @ Pure
6974 abstract DoFnSchemaInformation build ();
7075 }
7176
77+ @ Pure
7278 public abstract Builder toBuilder ();
7379
7480 /**
You can’t perform that action at this time.
0 commit comments