我正在使用Flink,并且有一个JSON字符串流到达我的系统,其中包含动态变化的字段和嵌套字段。所以我不能模拟这个传入的JSON并将其转换为静态POJO,而必须依赖于Map。我的第一个转换是使用GSON解析将JSON字符串流转换为Map对象流,然后将map包装在一个名为Data的DTO中。Data(map); // Data has getters, setters for the map and implements Serial
我想将流SQL放在Kafka中,以供Flink for CEP使用。这是一种好方法吗?
我知道动态模式定义在Flink上是不允许的,我需要应用它们可以在无界事件流上更改的规则。想象一下,有一个事物跟踪服务(如亚马逊网络服务中心)保持物理设备的状态,我也认为这是将每个设备的特定规则放入影子规则中的好方法,当影子参与者接收到传感器数据时,它可以发出数据,并将其规则添加到IoT作为规则引擎使用因此,我希望Flink执行传入