def to_upper()

in pyflink-examples/UDF/udf.py [0:0]


def to_upper(i):

    '''
    logging within a UDF is highly discouraged except in
    the case of debugging and exceptions. Use this as an example implementation.
    '''
    logging.info("Got {} in the toUpper function".format(str(i)))
    return i.upper()