- _accumulate(self, state, row)
- Altere temporalmente esta función para manejar el estado de proceso de acumulación de agregados.
- Parámetros
- estado
- (list<object>) La fila actual del estado.
- fila
- (list<object>) Una fila de entrada.
Esta función debe llamar a setState para cambiar el estado actual de la fila de entrada. El valor Python None se pasa cuando el valor de la base de datos es NULL.
- _cleanUp(self)
- Anule esta función para limpiar el AE una sola vez.
- _finalResult(self, state)
- Altere temporalmente esta función para manejar el estado de proceso de finalización para agregados.
- Parámetros
- estado
- (list<object>) La fila actual del estado.
- Devuelve
- (objeto) Resultado final de la agregación. Devuelve el valor de Python None para devolver NULL en la base de datos.
- _getFunctionResult(self, row)
- Sobreescriba esto para implementar la funcionalidad UDF o UDTF donde hay exactamente una salida por entrada.
- Parámetros
- fila
- (lista) La fila de entrada a la función.
- Devuelve
- fila (lista o valor único) El resultado de la función. Para los EA UDF, debe ser una lista con un valor o sólo el valor. En cualquier caso, este resultado debe coincidir con la firma de salida de la UDF/UDTF.
Para generar filas para una UDTF en la que no existe una correspondencia uno a uno entre la entrada y la salida, anule _ru- nUdtf en lugar de esta función. El valor de Python None se pasa cuando el valor de la base de datos es NULL, y debe devolverse None para devolver un valor de base de datos NULL.
- _getRemoteProtocolStatus(Class)
- Anule esta función para proporcionar una cadena de estado diferente a la llamada de estado del protocolo remoto.
- Devuelve
- (cadena) Estado actual del ejecutable.
- _handleRemoteProtocol(Class, código, datos)
- Reemplaza esta función para manejar la funcionalidad genérica del protocolo remoto.
- Parámetros
- código
- (entero) Código de protocolo remoto que identifica la solicitud de protocolo remoto.
- datos
- (cadena) Los datos del protocolo remoto.
- Devuelve
- (tupla<integer, cadena>) Tupla del código de salida, donde 0 significa O K, y los datos de retorno.
En general, un escritor de EA no anula esta función, pero esta capacidad se proporciona para el escritor de EA avanzado. Normalmente, un escritor AE anula uno de: _getRemoteProtocolStatus, _handleRemoteProtocol- ControlData, _handleRemoteProtocolRequest, o _handleRemoteProtocolStopRequest().
- _handleRemoteProtocolControlData(Class, datos)
- Anule esta función para manejar datos genéricos de control de protocolo remoto.
- Parámetros
- datos
- (cadena) Los datos recibidos del subsistema de protocolo remoto.
- Devuelve
- (cadena) Los datos que se enviarán al subsistema de protocolo remoto.
- _handleRemoteProtocolRequest(Class, solicitud)
- Sobreescriba esta función para manejar peticiones genéricas de protocolo remoto.
- Parámetros
- solicitud
- (cadena) La solicitud recibida del subsistema de protocolo remoto.
- Devuelve
- (cadena) Los datos que se enviarán al subsistema de protocolo remoto.
- _handleRemoteProtocolStopCommand(Class)
- Anule esta función para gestionar el comando de parada del protocolo remoto de una forma no estándar.
- La implementación por defecto llama a Class._cleanUpClass() y a sys.exit().
- _initializeState(self)
- Altere temporalmente esta función para manejar el estado de proceso de inicialización para agregados.
- _merge(self, state, inputState)
- Altere temporalmente esta función para manejar el estado de proceso de fusión para agregados.
- Parámetros
- estado
- (list<object>) El estado actual.
- inputState
- (list<object>) El estado a fusionar con el estado actual.
Esta función debe llamar a setState para cambiar el estado actual dado el estado de entrada. El valor Python None se pasa cuando el valor de la base de datos es NULL.
- _onIdle(Class)
- Anule esta función para gestionar el tiempo de inactividad de los EA remotos.
- _run(self)
- Altere temporalmente esta función para manejar la ejecución genérica de AE.
- Los redactores avanzados de EA pueden anular esta función. Se llama a la función _run para todos los EAs. En general, un escritor AE debe derivar de la clase Ae y sobreescribir _runUdtf, _ru- nUdf, _runUda, _runShaper, o _runSizer según corresponda.
- _runInstance(Class, instance)
- Altere temporalmente esta función para manejar la ejecución genérica de una instancia de AE.
- Parámetros
- instancia
- ( Ae ) La instancia Ae a ejecutar.
Esta función llama a _setup , _run , _cleanUp, done y close para una instancia AE especificada, y maneja las ex- cepciones apropiadamente. Normalmente, un redactor de EA no anula esta función, pero los redactores de EA avanzados pueden hacerlo.
- _runLocal(Class)
- Altere temporalmente esta función para manejar solo las AE locales.
- Esta función instantiza el AE y luego llama a _runInstance. Normalmente, un redactor de EA no anula esta función, pero los redactores de EA avanzados pueden hacerlo.
- _runRemote(Class)
- Anula esta función para manejar cómo se ejecutan los EAs remotos.
- Esta función crea una escucha remota AE, acepta peticiones del software Netezza, bifurca o inicia un hilo según corresponda, crea una instancia del AE y llama a _runInstance. También gestiona adecuadamente las excepciones. Normalmente, un redactor de EA no anula esta función, pero los redactores de EA avanzados pueden hacerlo.
- _runShaper(self)
- Altere temporalmente esta función para manejar la ejecución de un modelador.
- _runSizer(self)
- Altere temporalmente esta función para manejar la ejecución de un medidor.
- _runUda(self)
- Altere temporalmente esta función para manejar la ejecución de un agregado.
- En general, si el EA es un agregado, debe anular _initializeState, _aggregate(), _merge , y _fi- nalResult. Sin embargo, se pueden realizar ajustes más precisos anulando esta función.
- _runUdf(self)
- Altere temporalmente esta función para manejar la ejecución de una UDF.
- Por defecto, esta función recupera las filas de entrada y llama a _getFunctionResult. A continuación, emite el resultado de la llamada a la función. En consecuencia, un escritor AE puede anular _getFunctionResult para obtener una interfaz más sencilla de la funcionalidad UDF.
- _runUdtf(self)
- Altere temporalmente esta función para manejar la ejecución de una UDTF.
- Por defecto, esta función recupera las filas de entrada y llama a _getFunctionResult. A continuación, emite el resultado de la llamada a la función. Esta función debe anularse (en comparación con _getFunction- Result ) si un escritor AE desea emitir más o menos de 1 fila de salida por cada fila de entrada.
- _setup(self)
- Anule esta opción para configurar una sola vez la instancia AE.
- Esta función es llamada por _runInstance inmediatamente después de crear la instancia del AE. Es posible sobreescribir la función __init__ del AE para realizar la inicialización, sin embargo, es preferible realizar la inicialización personalizada en _setup para garantizar una configuración adecuada del sistema Python AE un- derlying antes de realizar la inicialización personalizada. De este modo, se gestionan mejor las excepciones durante la inicialización personalizada.