初始化场我与Apache弗林克流API的一个问题。 我可以设法建立整个CEP-环境与自定义数据源和源像使用标准的水槽时,“打印()”,一切工作正常。 这是我的片貌似现在: @RequiredArgsConstructor
public class EventDataConsumer extends RichSinkFunction<EventData>{
private final tran
我创建一个测试,看看我的弗林克模式功能超时正确。我使用这个弗林克斯佩克特和我有以下测试用例: @Test
public void SameDoor_TwoStatuses_OneSecondTimeoutPattern() {
// Arrange
long now = new Date().getTime();
DoorEvent event1 = new Doo