Package org.apache.beam.sdk.schemas

Interface ProjectionConsumer

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	Description
Map<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 Details

consumesProjection

Map<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().