data-stream

0热度

1回答

使用套接字编程从客户端程序发送数据的流（在VM中运行）到服务器程序（在主机OS）中的Java

客户端插座计划（在windows VM）生成按照下面的代码从1到10整数 public class ClientSocket { public static void main(String[] args) { try{ InetAddress inetAddress = InetAddress.getLocalHost(); String clie

3热度

2回答

是Spark流

DSTREAM提供的union两种类型两种类型工会之间有什么不同： StreamingContext.union(Dstreams) Dstream.union(anotherDstream) 所以我想知道什么是不同的，尤其是在并行性能。

0热度

1回答

Redis - 解析远程服务器提供的数据流

我在本地设置了Redis，我想连接到提供合成数据流的远程服务器，其格式为< ID，value>。到目前为止，我已经使用套接字连接到上面提到的服务器，读取数据流并打印出来。相反，我想将这些对存储在散列数据结构中（我将在稍后存储有关每个ID的更多信息）。问题是，我不知道如何解析数据流，以便使用hget以及如何连续使用。在更高层次上，我希望能够将传入数据流中的Name和Value作为参数传递给hget。

0热度

1回答

分类或数据流的GroupBy数据和流程与CEP分别

假设我有一个数据流 x:1, y:2 , z:3 , x:7 , y:-1, z:0, z:3 , z:2, y:3 ,x: 2 ,y:6 我怎么把x,y,z在自己的水桶和应用上我的CEP规则。 x:1, x:7,x: 2 y:2, y:-1, y:3 , y:6 z:3, z:0 , z:3, z:2 或以其他方式表达。如何将流分成这些类别（每个x，y，z一个流）。我会得到3个具有自

0热度

1回答

SplitStream动态输出键（选择）

这是我的代码。 SplitStream<MonitoringEvent> splitStream = inputStream.split(new OutputSelector<MonitoringEvent>() { @Override public Iterable<String> select(MonitoringEvent me) { List<Strin

0热度

1回答

与kafka连接的多个配置单元分区

我一直在尝试使用kafka连接将数据流数据转换为HDFS，并在配置过程中与配置单元集成。我的用例要求我使用“FieldPartioner”作为分区类。我的问题是，我无法获得多个分区。例子：我的例子JSON { "_id": "582d666ff6e02edad83cae28", "index": "ENAUT", "mydate": "03-01-2016",

0热度

1回答

Apache Kafka的Datastream生成器

我正在寻找一个简单的事件/数据流生成器，用于Kafka-broker在Hadoop框架的流工具上运行一些性能测试。到目前为止没有发现任它应该能够在非常短的时间（毫秒）内发送大量（大部分相同的）消息。谢谢！

0热度

1回答

如何通过单个通道控制ARINC429标签？

我使用ARINC 429协议通过使用Ballard设备在单个通道上传输4个不同的标签。 BTI SDK提供了暂停/恢复/停止频道的方式，但是我没有找到任何直接的方法来暂停频道上的任何特定标签？有没有什么解决办法可以让它工作？我主要是在寻找BTI42964.DLL提供的任何函数吗？

2热度

2回答

从C＃发送长字符串到Python的最快方式

我有一串长长的数据流连续传输，它是由我的C＃脚本生成的。我想用它作为Python机器学习模型的输入。什么是最快的&实现这种传输最简单的方法？我已经发现了一些可能的选项：使用套接字。使用http。写数据到从C＃的文件，并且从读取的Python 数据的文件作为参数，而Python运行在C＃或过程不同的东西？

0热度

1回答

集成/转换来自不同/不同源的数据而不存储它

我有一个用例。我想整合/转换来自不同/不同来源的数据而不存储它。数据源是数据库（oracle，db2等），Webservice（Rest/Soap），平面文件（CSV，XML，JSON），MQ转储，大型机系统。我想从这些来源获取数据，并进行某种智能转换和集成，并将其提供给我们的客户。它看起来像典型的ETL场景，但我的情况不同。我不允许存储绝望来源给出的数据，这就意味着，举个简单的例子，我从orac