Fonction scalaire en langage Python

1. Dériver une classe de " nzae.Ae. La classe de base s'occupe de la plus grande partie du travail, de sorte que vous appelez généralement la classe " class-method "run()"" . La fonction " run() instancie la classe, met en place la gestion des erreurs et appelle la fonction dérivée appropriée. Pour les AE basés sur l'UDF comme celui-ci, la fonction " _getFunctionResult() doit être remplacée, car elle est appelée une fois pour chaque ligne d'entrée. Enregistrez le code suivant dans un fichier appelé " applyop.py:

   import nzae
   class ApplyOpUdfAe(nzae.Ae):
   def _getFunctionResult(self, row):
   # OUR CUSTOM CODE WILL GO HERE.
   ApplyOpUdfAe.run()

2. Compléter le code Python personnalisé. Dans cet UDF, vous transmettez un opérateur de chaîne, qui est soit un signe plus (+) pour ajouter, soit un astérisque (*) pour multiplier, ainsi que deux nombres entiers. Le code renvoie soit le produit, soit la somme des nombres entiers. En SQL, une version simple de cette fonction peut être appelée par l'une ou l'autre des méthodes suivantes :

   SELECT applyop('+', 3, 5);

   ou

   SELECT applyop('*', 3, 5);

   Bien que l'exemple mentionné ne comporte qu'une seule entrée, le système NPS traite des flux d'entrées. Par conséquent, le système NPS est plus susceptible d'être utilisé :

   SELECT applyop(mytable.operator, mytable.value1, mytable.value2) FROM mytable;

   Dans le premier exemple, le système NPS prend les constantes "+", 3 et 5 et les transforme en un flux de longueur 1 contenant trois éléments. Une ligne est "vue" par " _getFunctionResult() avec les trois éléments qu'elle contient. En interne, tous les cas mentionnés sont traités de la même manière et l'on peut supposer qu'il y a plusieurs entrées dans l'AE " applyop

3. Saisir un code personnalisé pour gérer une ligne d'entrée, car la gestion de la boucle d'entrée est nécessaire pour transmettre une ligne à la fonction à la fois :

   import nzae
   class ApplyOpUdfAe(nzae.Ae):
   def _getFunctionResult(self, row):
   # BREAK APART OUR ROW OF INPUT.
   operator, leftInput, rightInput = row
   # HANDLE ADDITION.
   if operator == "+":
   return leftInput + rightInput
   # HANDLE MULTIPLICATION.
   if operator == "*":
   return leftInput * rightInput
   # ERROR ON ALL OTHER.
   self.userError("Unhandled operator to ApplyOp: '" + operator + "'.")
   ApplyOpUdfAe.run()

   La fonction 'self.userError() signale une erreur à l'utilisateur SQL. Ce qui est renvoyé par " _getFunctionResult() est le résultat de l'opération SQL. Comme il s'agit d'un UDF, le résultat ne peut comporter qu'une seule colonne. Un exemple ultérieur montre comment utiliser les UDTF pour éditer plusieurs colonnes. Lorsque le code est complet, il doit être déployé et enregistré.

Les AE Python ne nécessitent pas de compilation.