Package org.apache.beam.sdk.schemas
Interface ProjectionConsumer
-
@Experimental public interface ProjectionConsumer
AProjectionConsumer
is aSchema
-aware operation (such as aDoFn
orPTransform
) that has aFieldAccessDescriptor
describing which fields the operation accesses.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.Map<java.lang.String,FieldAccessDescriptor>
consumesProjection()
Returns a map from inputTupleTag
id to aFieldAccessDescriptor
describing which Schema fieldsthis
must access from the corresponding inputPCollection
to complete successfully.
-
-
-
Method Detail
-
consumesProjection
java.util.Map<java.lang.String,FieldAccessDescriptor> consumesProjection()
Returns a map from inputTupleTag
id to aFieldAccessDescriptor
describing which Schema fieldsthis
must access from the corresponding inputPCollection
to complete successfully. Fields not listed in theFieldAccessDescriptor
are assumed to be safe to drop from the input. InputPCollection
s not found in the keyset are implied to have valueFieldAccessDescriptor.withAllFields()
.
-
-