扩展添加了操作员设计和部署流分析过程在Flink或Spark。

这是测试版。请谨慎使用它，因为功能仍在开发中。

流分析过程是在streaming Nest运算符内部设计的。通过创建并向相应的集群提供连接对象来部署流程。

所设计的流程是平台独立的。只需更改所提供的连接对象，就可以将它们部署到其他平台上(也可以从Flink更改为Spark，反之亦然)。

部署的流作业可以通过使用流控制面板来监控和管理，该控制面板可以通过视图->显示面板菜单启用。

扩展提供了以下操作符:

• 流媒体

  • 输入输出

    • 卡夫卡水槽

    • 卡夫卡源

  • 流控制

    • 重复的流

    • 加入流

    • 连接流

    • 结合流

  • 转换

    • 总流

    • 过滤流

    • 地图流

    • 选择流

    • 解析字段流

    • Stringify字段流

    • 时间戳流

  • Infore项目

    • 金融服务器

    • 获取报价符号

    • 得到报价

    • 得到的深度

    • 报价或深度流

    • 合作伙伴服务

    • 流优化(在0.7.0中更新)

    • 概要数据引擎

    • 雅典娜在线机器学习引擎

    • 复杂事件预测引擎

    • Spring复杂事件预测引擎

    • 海事事件检测

    • 海上航迹融合(0.7.0新增功能)

  • 流巢

  • 在流上应用模型

版本0.7.0 (22-05-06)

• 增加了新的运营商海上航迹融合运营商:
  • 它集成了研究伙伴海上交通的跟踪融合功能。
  • 它允许将不同的输入数据流融合为一个联合的航迹数据流，以便进一步分析。
• 增加了已部署流工作流的持续优化(流优化操作符)与informix优化器服务的集成
  • 优化请求作为作业添加到流管理仪表板。如果待优化工作流的新物理(优化)版本可用，用户可以通过单击重新部署新版本。

版本0.6.1 (22-02-07)

• 增加了Kafka Source和Sink操作符的topic name参数检查
  • 检查主题名称是否无效和/或冲突字符。提供了用下划线替换它们的快速修复程序。
  • 如果主题名称包含无效字符，则抛出用户错误
• 添加了“早期时间序列分类引擎”操作符，以集成来自informix项目的合作伙伴服务，以便在流工作流中部署和使用合作伙伴的早期时间序列分类引擎。
• 修复了informix优化器服务的基准测试组件集成的错误。
• 修复了用于与foreforeoptimizer服务通信的流优化操作符的错误。

版本0.6.0 (21-12-15)

• 扩展的Beta版本
• 该扩展现在基于Kafka连接器扩展0.3.0
  • Kafka主题检测增加到Kafka Sink和Kafka Sink操作符
  • Kafka连接对象是由Kafka Connector扩展创建的
  • 增加了Kafka集群的安全连接选项(PLAIN, SASL, SSL)
• 该扩展附带了用于在Flink和Spark集群上部署RM模型的插件
• 现在可以对Flink和Spark连接进行连接检查
• 现在可以停止流程部署
• 增加了一个用户错误，以防在Streaming Nest操作符中没有添加流处理操作符。
• 重组运营商集团
• 添加一个新的Maritime Akka Cluster连接对象类来存储ip地址(以及任何其他必要的信息)，供Maritime Event Detection操作符使用
• 海事事件检测操作员现在可以区分作业类型(事件和融合)

版本0.5.0 (21-10-21)

• 增加了向Streaming Nest操作符的连接输入端口提供一个informix Optimizer连接对象的可能性。
  • 在本例中，定义流工作流的StreamGraph被序列化并上传到infforeoptimizer服务的文件服务器。
  • 将infforeoptimizer Service的文件服务器的主机和端口参数添加到相应的连接类中。
• 增加了新的操作符Timestamp Stream
  • 该操作符将时间戳放在流的事件上(将其分配给作为参数提供的键)。
• 用三个新参数(“域流”、“时间戳键”、“配置主题”)更新了复杂事件预测引擎操作符。
• 更新了流优化操作符，以符合infforeoptimizer服务的最新发展

版本0.4.0 (21-10-21)

• 增加了向Streaming Nest操作符的连接输入端口提供一个informix Optimizer连接对象的可能性。
  • 在本例中，定义流工作流的StreamGraph被序列化并上传到infforeoptimizer服务的文件服务器。
  • 将infforeoptimizer Service的文件服务器的主机和端口参数添加到相应的连接类中。
• 增加了新的操作符Timestamp Stream
  • 该操作符将时间戳放在流的事件上(将其分配给作为参数提供的键)。
• 用三个新参数(“域流”、“时间戳键”、“配置主题”)更新了复杂事件预测引擎操作符。
• 更新了流优化操作符，以符合infforeoptimizer服务的最新发展

版本0.4.0 (21009-14)

• 在流上添加了新的操作符应用模型，它允许部署在流流程中脱机训练的RapidMiner模型
  • 用于此的流集群需要有可用的RapidMiner Core
• 更新了复杂事件预测运算符
  • 增加参数k和偏移量重置
• 更新的流媒体仪表板
  • 改进的视觉效果和用户体验
  • 增加用于部署流作业的RM进程的进程位置。
• 更新流优化运算符
  • 连接到informix Optimizer服务的新连接对象
  • 可用的计算站点可以通过更新的端口结构更容易地定义
  • 逻辑工作流和优化工作流现在被分离在不同的子流程中
  • 调整配置参数和内部工作，以更改informix Optimizer服务的接口
• 固定的问题与大量登录的财务来源操作员

版本0.3.0 (21-03-08)

• 添加Spring复杂事件预测引擎操作符，在流分析工作流中部署Spring研究伙伴提供的预测功能
• 增加联合流运算符，对流分析工作流中的两个或多个输入流执行联合操作
• 更新了概要数据引擎操作员，以包括相应引擎的最新发展。

版本0.2.0 (2020-12-09)

• 读Kafka主题和写Kafka主题现在使用连接对象，也修复了使用远程集群的错误
• 添加流操作符(仅flink)，从流工作流中的SPRING访问财务数据服务器(引用流或深度流)
• 在RapidMiner Studio中添加了新的流媒体仪表板作为面板，以监视和管理部署的流媒体工作流
• 更新流优化操作符以使用连接对象，以获得更高级的参数处理，并将子流程拆分为两个子流程，一个处理逻辑工作流，另一个显示优化的工作流

版本0.1.0 (2020-10-26)

• 实现了主要功能的初始alpha版本。

• 主要功能为部署流分析过程实现

  • 增加了用于设计和部署流分析流程的流巢操作符

• 增加流操作符从/推卡夫卡(Kafka源，Kafka Sink)

• 增加了操作符从Kafka拉和转换到ExampleSet(读取Kafka主题)和转换ExampleSet到数据事件和推到Kafka(写Kafka主题)

• 增加了从SPRING访问财务数据服务器的操作符(获取报价符号、获取报价、获取深度)

• 添加了流操作符来执行几个基本的流功能(聚合流，复制流，加入流，连接流，过滤流，映射流，选择流，解析字段流，Stringify流)

• 添加了与info优化器(流优化操作符)的集成

• 增加了与不同info组件的集成(概要数据引擎，雅典娜在线机器学习引擎，复杂事件预测引擎，海事事件检测)