Flink CDC : Pipeline UDF : Python