Class GroupByKeyTransform<I>

    • Constructor Detail

      • GroupByKeyTransform

        public GroupByKeyTransform()
        GroupByKey constructor.
    • Method Detail

      • prepare

        public void prepare​(Transform.Context context,
                            OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<Object,​List>>> oc)
        Description copied from interface: Transform
        Prepare the transform.
        Parameters:
        context - of the transform.
        oc - that collects outputs.
      • onData

        public void onData​(I element)
        Description copied from interface: Transform
        On data received.
        Parameters:
        element - data received.
      • close

        public void close()
        Description copied from interface: Transform
        Close the transform.