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
