In the way i see it a SocketIIO.read() implementation should just emit String (or byte[]) back. So creating a PTransform that open the port and then on the expand() method create a loop to just read the String (or byte[]) and then emit the values into the pipeline (returning a PColletion<String (or byte[])>).
Hope it gives you an idea. On Wed, Aug 15, 2018 at 12:55 AM, Akshay Balwally <abalwa...@lyft.com> wrote: > Anyone know how Beam can take input from a port (or some other testable > timed input?) > https://stackoverflow.com/questions/51850595/apache-beam-input-from-ports > > -- > Akshay Balwally > Software Engineer > 9372716469 | > > <https://www.lyft.com/> > -- JC
