Hi there

I would like to use a socket stream as input for my Flink workflow in Python. 
This works in scala with the socketTextStream() method, for instance

val stream = senv.socketTextStream("localhost", 9000, '\n')

I cannot find an equivalent in PyFlink, although it is briefly mentioned in the 
documentation. 

Any help is much appreciated.

Philippe

Reply via email to