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()