Funzione di tabella semplice in linguaggio Python

Il codice di questo esempio crea una funzione tabella che accetta un numero variabile di rappresentazioni stringhe dell'ora separate da virgole (ad esempio "12:30:55,4:20:18"). La funzione produce una riga per ogni rappresentazione temporale. Ogni riga mostra l'ora, suddivisa nelle sue parti. Si noti che è necessario prendere il controllo dell'I/O per l'AE nel '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()

Distribuire lo script:

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

Registra la funzione tabella 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))"

Eseguire la query in 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)