title: Using Python user defined function in a Java Flink Job
body: <p>Is there anyway to use a python user defined function within a Java Flink Job or anyway to communicate for example the result of a transformation done by flink with java with a python user defined function to apply some machine learning things:</p>
  <p>I know that from pyFlink you can do something like this:</p>
  <pre><code>table_env.register_java_function(&quot;hash_code&quot;, &quot;my.java.function.HashCode&quot;)
  </code></pre>
  <p>But I need to do something like that but add the python function from java, or how can I pass the result of a java transformation to a Python UDF Flink job directly?</p>
  <p>I hope these questions are not to crazy, but I need to know if exist somehow to communicate Flink DataStream API with Python Table API having Java as main language? this means that from Java I need to do:
  Source -&gt; Transformations -&gt; Sink, but some of these transformations can trigger a Python function or a Python function will be waiting for some Java transformation to finish to do something with the Stream result.</p>
  <p>I hope someone understand what I'm trying to do here.</p>
  <p>Kind regards!</p>