Class CombineFnPartialTransform<K,​I,​A>

  • Type Parameters:
    K - Key type.
    I - Input type.
    A - Accum type.
    All Implemented Interfaces:
    Serializable, Transform<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​I>>,​org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​A>>>

    public final class CombineFnPartialTransform<K,​I,​A>
    extends NoWatermarkEmitTransform<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​I>>,​org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​A>>>
    Partially accumulates the given KVs(Key, Input) into KVs(Key, Accum). (Currently supports batch-style global windows only) TODO #263: Partial Combining for Beam Streaming TODO #264: Partial Combining with Beam SideInputs
    See Also:
    Serialized Form
    • Constructor Detail

      • CombineFnPartialTransform

        public CombineFnPartialTransform​(org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<I,​A,​?> combineFn)
        Constructor.
        Parameters:
        combineFn - combine function.
    • Method Detail

      • prepare

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

        public void onData​(org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​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.