class_docstr: An aggregation interface, similar to apche_beam.CombineFn.
docstr: Directly apply aggregate on inputs.
docstr_tok: ["Directly","apply","aggregate","on","inputs","."]
code: def __call__(self, *inputs, **named_inputs):
      """Directly apply aggregate on inputs."""
      return self.extract_output(
          self.add_inputs(
              self.create_accumulator(), *inputs, **named_inputs
          )
      )
  
imports: from typing import Any
label_desc: Use image node_id 4 for calling the AggregateFn obj's underlying member method code with example usage: obj.__call__() and returns: self