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