org.apache.beam.sdk.schemas

Interface ProjectionConsumer

@Experimental
public interface ProjectionConsumer

A ProjectionConsumer is a Schema-aware operation (such as a DoFn or PTransform) that has a FieldAccessDescriptor describing which fields the operation accesses.

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,FieldAccessDescriptor>	consumesProjection() Returns a map from input TupleTag id to a FieldAccessDescriptor describing which Schema fields this must access from the corresponding input PCollection to complete successfully.

Method Detail

consumesProjection

java.util.Map<java.lang.String,FieldAccessDescriptor> consumesProjection()

Returns a map from input TupleTag id to a FieldAccessDescriptor describing which Schema fields this must access from the corresponding input PCollection to complete successfully. Fields not listed in the FieldAccessDescriptor are assumed to be safe to drop from the input. Input PCollections not found in the keyset are implied to have value FieldAccessDescriptor.withAllFields().