MapElements
MapElements<InputT, OutputT>
is a PTransform of a PCollection of type InputT
to a PCollection of type OutputT
.
PCollection<? extends InputT> ~~[MapElements<InputT, OutputT>]~~> PCollection<OutputT>
Creating Instance
MapElements takes the following to be created:
MapElements is created using MapElements.via and MapElements.into utilities.
MapElements.via Utility
MapElements<NewInputT, OutputT> via(
Contextful<Fn<NewInputT, OutputT>> fn)
MapElements<InputT, OutputT> via(
InferableFunction<InputT, OutputT> fn)
MapElements<NewInputT, OutputT> via(
ProcessFunction<NewInputT, OutputT> fn)
MapElements<NewInputT, OutputT> via(
SerializableFunction<NewInputT, OutputT> fn)
MapElements<InputT, OutputT> via(
SimpleFunction<InputT, OutputT> fn)
via creates a MapElements for the given function.