flink-siddhi icon indicating copy to clipboard operation
flink-siddhi copied to clipboard

Published 20 hours ago • verified publisher icon haoch

StreamSerializer fails on compositeTypes and rowTypes

Open Wosin opened this issue 6 years ago • 2 comments

In StreamSchema there are methods isRowType() and is isCompositeType(). But they are not used in StreamSerializer, which makes it impossible to create SiddhiStream for those types.

Wosin avatar Apr 27 '18 11:04 Wosin

Any updates on this ?

Wosin avatar Jun 08 '18 13:06 Wosin

@Wosin Supported RowType in https://github.com/haoch/flink-siddhi/commit/a700abb4e8fe6ce8399efd3737a4d6ea70c7053b. For CompositeType, it's just an abstract class, while Pojo and Tuple are subclass of it, which are already supported.

haoch avatar Aug 13 '18 16:08 haoch