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
Hello Flink People :-)
I am trying to get my head around flink - is it a supported use case to
register multiple streams with possibly more than one transformation / action
per stream?
def main(args: Array[String]): Unit = {
val env = StreamExecutionEnvironment.getExecutionEnvironment
v
Hi,
I created a custom input format. Idea behind this is to read all binary
files from a directory and use each file as it's own split. Each split is
read as one whole record. When I run it in flink I don't get any error but
I am not seeing any output from .print. Am I missing something?
*p