Overridable member functions

  • _accumulate(self, state, row)

    Override this function to handle the accumulate process state of aggregates.

  • _cleanUp(self)

    Override this function for a one-time cleanup of the AE.

  • _finalResult(self, state)

    Override this function to handle the Finalize processing state for aggregates.

  • _getFunctionResult(self, row)

    Override this function to implement UDF or UDTF functions where there is exactly one output per input.

  • _initializeState(self)

    Override this function to handle the initialize processing state for aggregates.

  • _merge(self, state, inputState)

    Override this function to handle the merge processing state for aggregates.

  • _run(self)

    Override this function to handle generic running of AEs.

  • _runInstance(Class, instance)

    Override this function to handle generic running of an AE instance.

  • _runLocal(Class)

    Override this function to handle running only local AEs.

  • _runShaper(self)

    Override this function to handle running a shaper.

  • _runSizer(self)

    Override this function to handle running a sizer.

  • _runUda(self)_runUda

    Override this function to handle running an aggregate.

  • _runUdf(self)

    Override this function to handle running a UDF.

  • _runUdtf(self)

    Override this function to handle running a UDTF.

  • _setup(self)

    Override this function for a one-time setup of the AE instance.