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

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