问题标签 [apache-edgent]

Quarks 中的 IotfDevice 类有一个带有 optionsFile 的构造函数。该文件的格式是什么，必要的值是什么？

我根据本手册创建了一个源函数。

现在我想过滤这个流。我有这样的想法：

这是行不通的。有人知道如何过滤流吗？我不想更改请求 url 来预先进行过滤。

我最近遇到了边缘分析这个术语，并了解将智能推送到边缘设备的优势。现在开始实施，我已经通过了Apache Edgent和Kaa。就边缘设备的分析而言，两者似乎对我来说或多或少地执行了类似的工作，但 Kaa 完全是一个物联网平台，它具有边缘分析作为一项功能。哪个更高效，在行业中使用？

我有 3 个流：

我目前从 3 个 JSON 对象创建 3 个单独的设备事件：

相反，我想通过将这些流连接在一起并创建 1 个具有三个属性（Temperature、C02Level 和 isStationary）的 JSON 对象来创建单个事件。

这是取自Apache Edgent 文档的代码

我不明白元组到底是什么。代码如下：

我得到的错误是tuple cannot be resolved to a variable。我得到的错误到底是什么？谢谢你。

正如Apache Edgent 的文档中给出的那样， 我试图过滤掉我的传感器读数，其中温度传感器的值必须在 80 到 85 F 之间。

但是当我尝试连接传感器时，读数为 75F，并且没有显示如下消息：温度超出范围。

是不是过滤方法不起作用？如果是这样，请尝试帮助我。谢谢。

范围值设置为：

传感器对象是TempSensor ts

过滤部分：

输出：

假设以下代码片段：

调用后job = dp.submit(top)，执行拓扑的线程将继续在后台运行，直到 JVM 停止。

如何以编程方式停止此后台进程？当 Edgent 拓扑作为单独的进程与同一 JVM 中的其他任务一起运行时，这特别有用。我试图打电话job.cancel(true)，但这并不能解决问题。任务继续运行...

我正在使用 Apache Edgent（Java 框架）每 3 秒从 Raspberry Pi 上的 HCSR04 超声波传感器轮询一次值。我使用过滤器来获取 50cm 到 80cm 的值。

我想在过滤值时显示一些消息。当值与我的过滤器不匹配时，我可以轮询它们，但是当它们匹配时我不返回，那没关系。但是，我只想表明使用 Apache Edgent 库过滤了一个值。我知道我可以在public double get()方法上做一些事情，但我想知道我是否可以用 Apache Edgent 的一些方法来做这个技巧。

公共类 UltrasonicStream 实现供应商{

}

我想知道我是否可以更改已经提交给 Flink 的作业的操作符。假设我有一个字数统计程序，并且上面有一个过滤器，只计算大于 3 个字符的单词。我想在运行时更改此过滤器的参数。我的第一个猜测是 Flink（以及其他数据流引擎 Spark、Storm、Apache Edgent）无法做到这一点，因为作业已经在env.execute(). 有谁知道这样做的任何方法？

我猜这个问题（在运行时部署流处理拓扑？）与我想要的有关，但解决方案仍然不是我想要的动态。

谢谢

基本上，我使用 CoFlatMapFunction （https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.html）过滤流并在运行时更改过滤器参数，我为此使用 Flink。我想使用 Apache Edgent TStream ( https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html ) 做同样的事情，但它没有 CoFlatMapFunction。如果我使用联合，它将不起作用，因为流不同，我不允许进行联合。如果我使用过滤器，我将不会有我想要的动态行为。有什么建议吗？

谢谢