Python Functions — Apache Tajo 0.11.0 documentation

Please note that you can specify multiple paths with ',' as a delimiter. Each file can contain multiple functions. Here is a typical example of a script file.
# /path/to/udf1.py
+# /path/to/udf1.py
 
-@output_type('int4')
+@output_type('int4')
 def return_one():
   return 1
 
-@output_type("text")
+@output_type("text")
 def helloworld():
-  return 'Hello, World'
+  return 'Hello, World'
 
-# No decorator - blob
+# No decorator - blob
 def concat_py(str):
   return str+str
 
-@output_type('int4')
+@output_type('int4')
 def sum_py(a,b):
   return a+b
 
@@ -250,7 +250,7 @@ After that, you can register your functi
 By default, every function has a return type of BLOB.
 You can use Python decorators to define output types for the script functions. Tajo can figure out return types from the annotations of the Python script.
 
-output_type: Defines the return data type for a script UDF in a format that Tajo can understand. The defined type must be one of the types supported by Tajo. For supported types, please refer to Data Model.
+output_type: Defines the return data type for a script UDF in a format that Tajo can understand. The defined type must be one of the types supported by Tajo. For supported types, please refer to Data Model.
 
 
 
@@ -267,7 +267,7 @@ You can use Python decorators to define
 Function registrationÂ¶
 To define your Python aggregation functions, you should write Python classes for each function.
 Followings are typical examples of Python UDAFs.
-# /path/to/udaf1.py
+# /path/to/udaf1.py
 
 class AvgPy:
   sum = 0
@@ -280,22 +280,22 @@ Followings are typical examples of Pytho
       self.sum = 0
       self.cnt = 0
 
-  # eval at the first stage
+  # eval at the first stage
   def eval(self, item):
       self.sum += item
       self.cnt += 1
 
-  # get intermediate result
+  # get intermediate result
   def get_partial_result(self):
       return [self.sum, self.cnt]
 
-  # merge intermediate results
+  # merge intermediate results
   def merge(self, list):
       self.sum += list[0]
       self.cnt += list[1]
 
-  # get final result
-  @output_type('float8')
+  # get final result
+  @output_type('float8')
   def get_final_result(self):
       return self.sum / float(self.cnt)
 
@@ -309,20 +309,20 @@ Followings are typical examples of Pytho
   def reset(self):
       self.cnt = 0
 
-  # eval at the first stage
+  # eval at the first stage
   def eval(self):
       self.cnt += 1
 
-  # get intermediate result
+  # get intermediate result
   def get_partial_result(self):
       return self.cnt
 
-  # merge intermediate results
+  # merge intermediate results
   def merge(self, cnt):
       self.cnt += cnt
 
-  # get final result
-  @output_type('int4')
+  # get final result
+  @output_type('int4')
   def get_final_result(self):
       return self.cnt
 
@@ -368,7 +368,7 @@ Followings are typical examples of Pytho
 
   
     
-        © Copyright 2015, Apache Tajo Team.
+        © Copyright 2016, Apache Tajo Team.
     
   
 
@@ -388,7 +388,7 @@ Followings are typical examples of Pytho
     
@@ -731,7 +731,7 @@
 
   
     
-        © Copyright 2015, Apache Tajo Team.
+        © Copyright 2016, Apache Tajo Team.
     
   
 
@@ -751,7 +751,7 @@
     
@@ -224,7 +224,7 @@
 
   
     
-        © Copyright 2015, Apache Tajo Team.
+        © Copyright 2016, Apache Tajo Team.
     
   
 
@@ -244,7 +244,7 @@