问题标签 [infosphere-spl]

系统：在 Windows Server 上运行 VMPlayer。一台 VM 正在播放 IBM Infosphere Streams (3.2) QuickStart Edition 和其他 MessageSight(1.1) 虚拟设备的映像。

使用 MQTTSource Operator 时出现以下编译错误

sdk 路径是 IBM MessageSight 的 SDK。我正在尝试使用 MQTT 运算符将流与 MessageSight 连接。SDK有问题还是我的代码有问题？请在下面找到代码。

我有一个字符串，并说我想检查字符串的最后 3 位数字的某个范围。

如果字符串像 sasdaX01，我需要检查字符串的最后三位数字是否在 X01-X50 之间。

任何帮助将不胜感激。

在自定义运算符中，我试图打开一个在启动时提交的文件，并对文件中的值进行标记，并将这些值与其他文件的输入流进行比较。

我正在 IBM Streams 中探索 Java Application Api，因此它看起来很有希望。我能够创建拓扑并在分布式模式下独立运行它们。

现在我正在尝试查看如何从 Java 拓扑中调用 R 脚本。我正在考虑的一种方法是在我的 Java 拓扑中使用 com.ibm.streams.rproject::RScript 运算符。

这是我的完整代码：

但是当我在拓扑之上运行时，我收到以下错误：

你能告诉我我做错了什么吗？对在 Java API 中使用 SPL 运算符有任何帮助吗？

谢谢苏德希尔

我正在使用 IBM Streams 4.1.1 我不能在我的 Java 运算符中使用 Elasticsearch 客户端，因为它具有传递依赖 guava-18.0 lib

当我提交我的工作时，我看到 NoSuchMethodError ：com/google/common/util/concurrent/MoreExecutors.derectExecutor

发生这种情况是因为 IBM 流在 ext/lib guava-14 中有。如何解决这个问题？

I have been searching for awhile now on how to use a customized Java operator withing infosphere streams Java API

What I need is after writing a customized operator like below ...

I want to use it like the below ....

我想知道 infosphere 流中是否有两个功能可用，但我在其他任何地方都找不到。

1) 据我所知，当 InfoSphere Streams 应用程序启动时，所有操作员都部署在集群中的主机上。是否可以根据先前操作员的结果部署特定操作员？这样部署就在作业期间发生（而不仅仅是在主机发生故障时）。

2) 此外，据我所知，存在允许指定哪些 Operator 将部署到哪些主机的标签。是否可以在 Job 运行时更改主机标签？除了问题 (1)，我是否有可能在运行时根据作业期间发生的计算将 Operator 部署到特定机器？

谢谢，汤姆。

我想通过运算符捕获元组/秒的数量并将其记录在文件中。我不能使用“Throttle Operator”自己设置元组速率。另外，再次补充一下，我不是在谈论通过控制台捕获信息，而是通过 SPL 应用程序。

我正在将 3.0 代码迁移到新的 4.2 框架中。我面临一些困难：

1. 如何在新的 4.2 框架中进行 CDR 级重复数据删除？（注意：表重复数据删除已经完成）。

2. 在哪里实施 PostDedupProcessor - 上下文或链槽自定义？在这两种情况下，我需要从列表中删除重复的哈希码还是只拒绝元组？在这里，我也在为一些元组进行列更新。

3. 我的文件没有进入存档。临时输出文件正在生成，并且太空且位于加载目录之外。可能的原因是什么？- 我已经彻底检查了配置参数，并且在放置日志后，似乎从变压器自定义发送了正确的输出，所以我不知道它卡在哪里。我已经为日志打印了 TableRowGenerator 流（DataProcessor 结束）。

我正在尝试在 Streams 3.2 中编写一个小型 SPL 程序

因为我需要使用 filesink 生成文件，并且必须使用 FTPCommand 将相同的文件传输到另一台服务器。

我已将com.ibm.streamsx.inet包复制到 path 中$STREAM_INSTALL/toolkit，但我收到一条错误消息；

Streams 4.2 也是如此。即使这个包在流 4.2 版本中可用，我仍然得到同样的错误。

谁能帮帮我吗？