Apache Tajo - Fungsi Kustom

Apache Tajo mendukung fungsi yang ditentukan pengguna / kustom (UDF). Fungsi khusus dapat dibuat dengan python.

Fungsi khusus hanyalah fungsi python biasa dengan dekorator “@output_type(<tajo sql datatype>)” sebagai berikut -

@ouput_type(“integer”) 
def sum_py(a, b): 
   return a + b;

Skrip python dengan UDF dapat didaftarkan dengan menambahkan konfigurasi di bawah ini di “tajosite.xml”.

<property> 
   <name>tajo.function.python.code-dir</name> 
   <value>file:///path/to/script1.py,file:///path/to/script2.py</value> 
</property>

Setelah skrip terdaftar, mulai ulang cluster dan UDF akan tersedia tepat di kueri SQL sebagai berikut -

select sum_py(10, 10) as pyfn;

Apache Tajo juga mendukung fungsi agregat yang ditentukan pengguna tetapi tidak mendukung fungsi jendela yang ditentukan pengguna.