distributed-computing

8熱度

3回答

我是分佈式系統的新手，我想了解CRDT的概念。我意識到，它有三個符號： Conflict-free Replicated Data Type Convergent Replicated Data Type Commutative Replicated Data Type 誰能給我們在分佈式系統中使用CRDT的例子嗎？非常感謝。

1熱度

1回答

Infinity vs. mantl

我最近偶然發現了http://mantl.io/和https://mesosphere.com/infinity/。但是，我不確定每種方法的優點。到目前爲止，我知道mantl集成了ELK，calico，vault，traefik等一些組件，這些組件非常適合普通應用程序。而無窮大似乎非常適合物聯網/大數據分析應用。你能幫我解釋每種方法的區別/優點嗎？

0熱度

2回答

如何使用Oracle Coherence在分佈式系統上生成唯一的ID？

我有一個使用Oracle Coherence進行緩存功能的分佈式Java應用程序。我如何使用它爲分佈式系統生成唯一的UUID？我很確定這可以通過利用Coherence的緩存功能來實現序列生成器來完成，如here。 Cassandra有TimeBaseUUID，我試圖找出Coherence上是否有類似的東西。

-1熱度

1回答

錯誤而使用distrubuted陣列中的朱莉婭

我學習並行計算這個要使用分佈式陣列朱莉婭，但我在使用它的圖書館 ERROR: ArgumentError: DistributedArrays not found in path 我使用Ubuntu 14.04和Julia面臨的一些錯誤版本0.4.2 請幫我解決這個問題

0熱度

1回答

用於給定場景的進程或線程？

我有一個場景，我感到困惑的使用線程或進程：我有一個會談到由不同的公司提供了幾個其他的第三方網絡應用程序，並從這些應用程序中提取數據的應用程序。所以基本上我的應用程序會碰到這些第三方應用程序提供的api，帶來大量數據並將它們轉儲到數據庫中。現在有許多因素顯著喜歡這裏 - 網絡延遲，數據庫的讀/寫，快/慢服務器在兩端等，所以基本上是應用在很大程度上耗費時間和資源，其性能取決於多種因素。現在對於帶

1熱度

1回答

MPI_Gather 2D陣列

N是4，N_glob也是。它恰好是相同的大小。 p是4 下面是代碼的一小部分： float **global_grid; float **gridPtr; lengthSubN = N/pSqrt; subN = lengthSubN + 2; grid = allocate2D(grid, subN, subN); .. MPI_Type_contiguous(lengthSubN,

2熱度

1回答

MPI_Gather（）將中心元素合成爲全局矩陣

這是來自MPI_Gather 2D array的後續問題。這裏的情況是： id = 0 has this submatrix |16.000000| |11.000000| |12.000000| |15.000000| |6.000000| |1.000000| |2.000000| |5.000000| |8.000000| |3.000000| |4.000000| |7.00000

0熱度

1回答

查詢大量csv文件的工具

我們有大量的csv文件，文件/目錄按日期和其他幾個因素進行分區。例如，文件可能被命名爲/data/AAA/date/BBB.csv 有成千上萬個文件，有些文件在GB範圍內。總數據大小在兆兆字節。他們只是附加到，通常是批量，所以寫性能並不重要。我們不想將其加載到另一個系統中，因爲我們運行了幾個重要的流程，這些流程依賴於能夠快速流式傳輸文件，而這些文件是用C++編寫的。我正在尋找工具/庫，這將允許

0熱度

1回答

如何通知客戶端即時消息（IM）應用程序的更新？

我已經通過了關於這個話題的不同的問題，但是，他們都沒有清除我通過客戶端通知服務器 - 客戶端IM應用程序的最佳方法的懷疑。問題：整個問題是如何通知客戶端應用程序的更新。我alread看到以下方法：客戶不斷檢查更新：不時，客戶端應用程序執行的服務器進行檢查，看是否有針對特定用戶的更新; 問題：它根本不是performatic。假設你有一百萬用戶，他們每個人都會每秒檢查一次新的更新。即將發佈的服

1熱度

1回答

最後一個分區上的Spark轉換非常緩慢

我正在運行一種迭代算法，在每次迭代中，每個值的列表都被分配一組鍵（1到N）。隨着時間的推移，文件在鍵上的分佈會變得不對稱。我注意到經過幾次迭代，合併階段，似乎RDD的最後幾個分區上的事情似乎開始非常緩慢。我的變換如下： dataRDD_of_20000_partitions.aggregateByKey(zeroOp)(seqOp, mergeOp) .mapValues(...)