在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
开源软件名称:reactor-ql开源软件地址:https://gitee.com/jetlinks/reactor-ql开源软件介绍:用SQL来描述ReactorAPI进行数据处理Reactor + JSqlParser = ReactorQL 场景
特性
例子引入依赖 <dependency> <groupId>org.jetlinks</groupId> <artifactId>reactor-ql</artifactId> <version>{version}</version></dependency> 用例: ReactorQL.builder() .sql("select avg(this) total from test group by interval('1s') having total > 2") //按每秒分组,并计算流中数据平均值,如果平均值大于2则下游收到数据. .build() .start(Flux.range(0, 10).delayElements(Duration.ofMillis(500))) .doOnNext(System.out::println) .as(StepVerifier::create) .expectNextCount(4) .verifyComplete(); 更多用法请看 单元测试 |
请发表评论