Re: Reading byte[] from socket

Posted by Fabian Hueske-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Reading-byte-from-socket-tp14525p14529.html

Hi Paolo,

have a look at SocketTextStreamFunction [1] which is internally used when StreamExecutionEnviornment.socketTextStream() is called.

Best, Fabian

[1] https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java

2017-07-29 13:27 GMT+02:00 Paolo Cristofanelli <[hidden email]>:

Hi,

I would like to read a stream of byte[] from a socket. I know the "writeToSocket" function that allows you to specify a serialization schema to write your stream. 

I would like to do the same but for reading, specifying a deserialization schema that allows me to retrieve a stream of the class I have written before.

Best Regards

Paolo