Overridable member functions
- _accumulate(self, state, row)
- Override this function to handle the accumulate process state of aggregates.
- _cleanUp(self)
- Override this function for 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 to implement UDF or UDTF functionality where there is exactly one output per input.
- _getRemoteProtocolStatus(Class)
- Override this function to provide a different status string to the remote protocol status call- back.
- _handleRemoteProtocol(Class, code, data)
- Override this function to handle generic remote protocol functionality.
- _handleRemoteProtocolControlData(Class, data)
- Override this function to handle generic remote protocol control data.
- _handleRemoteProtocolRequest(Class, request)
- Override this function to handle generic remote protocol requests.
- _handleRemoteProtocolStopCommand(Class)
- Override this function to handle the remote protocol stop command in a non-standard way.
- _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.
- _onIdle(Class)
- Override this function to handle idle time for remote AEs.
- _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.
- _runRemote(Class)
- Override this function to handle how remote AEs are run.
- _runShaper(self)
- Override this function to handle running a shaper.
- _runSizer(self)
- Override this function to handle running a sizer.
- _runUda(self)
- 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 for one-time setup of the AE instance.