MaxCompute auto increment PythonUDF

  1. 云栖社区>
  2. 阿里巴巴大数据 —玩家社区>
  3. 博客>
  4. 正文

MaxCompute auto increment PythonUDF

隐林 2018-04-14 00:50:35 浏览1976
展开阅读全文

 有一些时候需要生成一个自增的id,以便能和mysql的表对应进行同步。参考了相关文档,写了一个python版的udf。

# coding=utf-8
from odps.udf import annotate
@annotate("*->bigint")
class AutoIncrement(object):
    count=0
    def evaluate(self,*args):
        base =0
        if len(args)==1 and isinstance(args[0],(int,long)) and args[0]>=0 :
            base=args[0]
        self.count=self.count+1
        return s

网友评论

登录后评论
0/500
评论
隐林
+ 关注