Función de tabla simple en lenguaje Python

El código de este ejemplo crea una función de tabla que toma un número variable de representaciones de cadenas de tiempo separadas por comas (por ejemplo "12:30:55,4:20:18"). La función produce una fila por cada representación temporal. Cada fila muestra la hora, dividida en sus componentes. Tenga en cuenta que debe tomar el control de la E/S para el AE en el ' def _runUdtf() function.

import nzae
class TimeSplitManyAe(nzae.Ae):
def _runUdtf(self):
for row in self:
for timeString in row[0].split(","):
self.output(timeString.split(":"))
TimeSplitManyAe.run()

Despliegue el script:

$NZ_EXPORT_DIR/ae/utilities/bin/compile_ae --language python64 \
--template deploy ./timeSplitMany.py --version 3

Registra la función de mesa AE:

$NZ_EXPORT_DIR/ae/utilities/bin/register_ae --language python64 --version 3 \
--template udtf --exe timeSplitMany.py \
--sig "time_split_many(varchar(1000))" \
--return "table(hour varchar(2), minute varchar(2), second varchar(2))"

Ejecute la consulta en nzsql:

SELECT * FROM TABLE WITH FINAL (time_split_many('13:22:47,22:12:45,03:22:09'));
HOUR | MINUTE | SECOND
------+--------+--------
13 | 22 | 47
22 | 12 | 45
03 | 22 | 09
(3 rows)