flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Swapnil Chougule <the.swapni...@gmail.com>
Subject RawSchema as deserialization schema
Date Mon, 05 Sep 2016 13:50:00 GMT
I am using Kafka consumer in flink 1.1.1 with Kafka 0.8.2. I want to read
byte array as it is in datastream. I tried to use RawSchema as
desrialization schema but couldn't find same 1.1.1.
I want to know whether I have to write my custom  implementation for same ?
Can somebody help me to sort out same ?

Also passing byte[] to next operator is supported as far as serialization
is concerned ?

View raw message