Apach Flink CEP“至少”条件

文章/答案/技术大牛

发布

2回答

apache-flink

我正在尝试创建一个匹配“至少”出现的CEP模式。{ } }没有解决我的问题，因为条件将继续失败

浏览 7提问于2017-06-29得票数 0

1回答

为下一个条件提供上下文

apache-flink、complex-event-processing、flink-cep

有什么方法可以用Flink CEP库创建这个模式吗？input List(1,2,2,2,3,3,2,1,1,1,3,0,1)List(2,2,2,3)List(1,1,1) 我知道有很多方法可以通过Flink本身来完成它，但是我想用CEP来完成它，我认为它需要支持将上下文传递到下一个条件，对吗？如果是这样的话，Flink CEP是否可以传递上下文或修改流中的事件，并将一些额外的数据传递给下一个条件？

浏览 6提问于2022-09-10得票数 0

回答已采纳

1回答

如果我们将返回布尔值的函数传递给Flink CEP的where子句，它会以分布式方式工作吗？

apache-flink、flink-streaming、flink-cep

我正在使用Flink CEP模块，我想知道是否将一个函数传递给where子句，它将返回布尔值，它是否会以分布式方式工作。示例-：val pattern= Pattern.start("begin").where(v=>booleanReturningFunction(v)) 上述代码在以简单条件作为CEP的flink作业提交时

浏览 6提问于2020-04-19得票数 0

回答已采纳

2回答

IntelliJ集成开发环境警告Flink CEP未知错误

scala、intellij-idea、apache-flink、complex-event-processing

我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/cep.html教程中所示的CEP.pattern(input,pattern)来创建一个PatternStream时，集成开发环境说它“无法解析重载方法”，它指的是pattern方法。import

浏览 50提问于2020-01-14得票数 0

回答已采纳

2回答

Apache如何检测事件是否在x秒内发生？

java、apache-flink、flink-streaming、flink-cep

connectionConfig, // config for the RabbitMQ connection }); PatternStream<String> timedOutPatternStream = CEP.pattern

浏览 0提问于2018-05-15得票数 2

回答已采纳

1回答

为什么Flink Cep一直在等待一个新的条目来捕获模式？

apache-kafka、apache-flink、flink-streaming、flink-cep

我正在制作一个Flink CEP应用程序，通过Kafka读取数据。当我试图捕捉模式时，当它之后没有数据时，接收器操作就不会发生。例如，我希望A-> B-> C作为一个模式。卡夫卡提供了A，B，C数据。ActionID='2.24'}DS::2> {"ActionID":"2.24"}4> {ActionID='2.24'} 那么，为什么在满足<e

浏览 1提问于2021-05-21得票数 0

2回答

带有列表的Apache flink pattern条件

java、apache-flink、complex-event-processing

我有一个条件列表(来自json的获取规则).Data(Json)来自kafka服务器。我想用这个列表过滤数据。但它不起作用。我该怎么做呢？对于keyedstream和警报，我不是很确定。com.google.gson.Gson;import com.google.gson.JsonParser;import org.apache.flink.cep.P

浏览 1提问于2017-09-21得票数 0

1回答

Flink和动态模板识别

templates、stream、apache-flink、flink-cep

我们计划使用Flink CEP根据一些动态模板处理大量事件。系统必须识别事件链(有时是带有条件和分组的复杂链)。模板将由用户创建。换句话说，我们必须在不接触代码的情况下创建复杂的模板。是否可以使用Apache Flink来解决此问题？Filnk支持动态模板吗？

浏览 3提问于2016-10-13得票数 1

2回答

无法在由ClassNotFoundException引起的Flink仪表板版本1.3.2中执行CEP模式

apache-flink、flink-streaming、flink-cep

我在仪表板和IntelliJ中都使用Flink 1.3.2。ClassNotFoundException说，当我从源代码构建Flink时，我看到了很多警告消息，这使我相信迭代条件类没有包含在jar中，因为错误也是如此。下面是错误 Caused by: java.lang.NoClassDefFoundError: org/apache/flink/cep/pattern/conditions/IterativeConditionjava.lang

浏览 1提问于2017-10-28得票数 0

回答已采纳

1回答

Flink CEP中的Context#currentProcessingTime

scala、apache-flink、flink-cep

使用Flink CEP时，Context具有currentProcessingTime属性。使用System.currentTimeMillis()和这种方法有区别吗？这里有一个小实验，看起来这些值几乎是相等的(至少在这个简单的场景中是这样)。import org.apache.flink.api.scala._ valIterativeCondition.Context[Int]): Boolea

浏览 77提问于2019-12-29得票数 0

1回答

如何停止Apache模式？

apache-flink、flink-streaming、flink-cep

最好使用的是: KeyedProcessFunction (带有状态、定时器、if-逻辑块)或Flink CEP模式库？。、state.clear()...you将理解我)，也可以使用条件和量化器使用Flink CEP库。如何停止flink CEP模式？

浏览 4提问于2020-08-13得票数 1

回答已采纳

1回答

Flink CEP在匹配时从状态中清除所有以前的事件

apache-flink、flink-streaming、flink-cep

我在flink CEP中有一个特殊的情况，其中所有事件在单个匹配上都会被丢弃。例如，让我们以Apple，All，Bulb，Bee，Bell的输入为例。条件是单词以A开头，单词以B开头。

浏览 22提问于2020-09-29得票数 0

1回答

如何利用Flink CEP实现与Brute强制登录和端口扫描攻击相匹配的模式

apache-flink、flink-streaming、flink-cep、flink-batch

这里的挑战是，在普通CEP中，我们将值与常量(如"event“= login )进行比较。在这种情况下，标准是不同的，就像在蛮力攻击的情况下，我们有如下的标准。

浏览 4提问于2020-09-29得票数 0

1回答

何时flink将清除flink cep sql中的空闲状态？

apache-flink、flink-sql、flink-cep

我使用flink cep sql和闪烁计划器。由于我将状态ttl和cep间隔设置为10s，状态的大小在启动10秒后应该是一个固定的数字。是否有我没有配置的配置？

浏览 3提问于2021-12-08得票数 0

回答已采纳

1回答

在Apache中动态添加模式而不重新启动作业

apache-flink、flink-streaming、flink-cep

我的用例是，我希望将不同的CEP模式应用到同一个数据存储区。CEP模式是动态出现的&我希望将它们添加到flink中，而不必重新启动作业。虽然所有条件都可以通过实现IterativeCondition的自定义类来处理，但我的主要问题是，时态条件只接受TimeWindow，这是不能处理的。原因是我将流应用于模式使用: PatternStream matchStream = CEP.pattern(tmatchStream，pattern)；但是"tmatchStream“

浏览 0提问于2018-03-13得票数 3

1回答

CEP示例的简单Scala API不显示任何输出

scala、apache-flink、flink-streaming、flink-cep

我正在编写一个简单的示例，用于在Flink中使用最新的Github 1.1-SNAPSHOT版本测试新的Scala API for CEP。pattern : Pattern[(String, Long, Int), _] = Pattern.begin("start").where(_._3 < 4) 此外，当尝试添加阶段时，代码无法编译。我尝试

浏览 2提问于2016-05-25得票数 1

1回答

Scala中单个模式的Flink CEP迭代条件

scala、apache-flink、complex-event-processing、flink-cep

我面临的问题是，我无法在scala中的单个CEP模式上执行一个sum。我希望检测特定customerID的和大于6100的时间。我正在向CEP.pattern(.)提供一个键流。("amount").toString.toLong)>6100 && v.get("state").toString=="FAILED"我的输入是avro格式的，Flink

浏览 2提问于2019-12-27得票数 0

回答已采纳

1回答

FLINK CEP (Java 8) -通过匹配模式持久的“身份”

java、apache-flink、flink-cep

我试图使用FLINK-CEP来衡量一个市场上从BidState.OPEN到BidState.Closed的投标时间。我有一个条件，在patternStream.process，它只允许开放和结束出价与相同的ID成对，因为他们应该是。} PatternStream<BidEvent> patternStream = CEP.pattern(BidEventDataStream

浏览 0提问于2019-05-28得票数 0

回答已采纳

2回答

未能执行目标生成所需的原型不存在(org:flink-演练-datastream-java)

java、maven、apache-flink

安装先决条件之后，我执行以下命令： -DarchetypeGroupId=org.apache.flink \ -DarchetypeArtifactId@ org.apache.flink:flink-scala_${scala.binary.version}:1.15.0, C:\Users\bk73027\Projects\FlinkDemo\flink\bk73027\Projects\FlinkDemo\flink</

浏览 7提问于2022-06-24得票数 1

回答已采纳

1回答

FLINK forBoundedOutOfOrderness + CEP

apache-flink

我正在尝试在无序流事件的FLINK上实现CEP模式。.withTimestampAssigner((event, timestamp) -> event.getGeneratedDate().toEpochSecond())) 我的模式通过以下代码链接到我的流： SingleOutputStreamOperator<DataOutput> enterStream = CEP</em

浏览 11提问于2022-01-28得票数 0

点击加载更多