search

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)
Apache License 2.0
243 stars 96 forks source link

StreamSerializer fails on compositeTypes and rowTypes #5

Open Wosin opened 6 years ago

Wosin commented 6 years ago

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 commented 6 years ago

Any updates on this ?

haoch commented 6 years ago

@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.