You have to create your own implementation that deserializes the byte
arrays into whatever type you want to use.
On 13.06.2017 13:19, AndreaKinn wrote:
But KeyedDeserializationSchema has just 2 implementations:
TypeInformationKeyValueSerializationSchema
JSONKeyValueDeserializationSchema
The first give me this error:
06/12/2017 02:09:12 Source: Custom Source(4/4) switched to FAILED
java.io.EOFException at
org.apache.flink.runtime.util.DataInputDeserializer.readUnsignedByte(DataInputDeserializer.java:306)
while the JSONObject obviously doesn't fit my needs.
I thinking about to implement a custom deserialiser but honestly I'm a
newbie and I don't know how to start.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-get-keyed-messages-from-Kafka-tp13687p13689.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
