Page History

@udf(input=[DataTypes.BIGINT(), DataTypes.BIGINT()], output=DataTypes.BIGINT())

class Multiply(ScalarFunction):

   def eval(self, x, y):

       return x * y

  def is_deterministic(self):

        return False

@udtf(input=[DataTypes.STRING()], output=DataTypes.STRING())

class Split(TableFunction):

   def eval(self, x):

       for e in x.split(“#”):

           yield e

class SumAcc(object):

   def __init__(self)

       self.sum = 0

@udaf(input=[DataTypes.BIGINT()],

            output=DataTypes.BIGINT(),

            accumulator=DataTypes.ROW([DataTypes.FIELD(“sum”, DataTypes.BIGINT())]))

class Sum(AggregateFunction):

   def accumulate(self, accumulator, input):

       accumulator.sum += 1

   def reset(self, accumulator):

       accumulator.sum = 0

   def create_accumulator(self):

       return SumAcc()

   def get_value(self, accumulator):

       return accumulator.sum

@udf(input=[DataTypes.BIGINT(), DataTypes.BIGINT()], output=DataTypes.BIGINT(), deterministic=False)

def multiply(x, y):

    return x * y

@udtf(input=[DataTypes.STRING()], output=DataTypes.STRING())

def split(self, x):

    for e in x.split(“#”):

        yield e