apache-apex

4熱度

1回答

由於兩者都是一次處理事件的流式框架，這兩種技術/流式框架之間的核心架構差異是什麼？另外，哪一個比另一個更合適？

0熱度

2回答

我一直在廣泛搜索INTERNET，以便在Apache Apex中使用web-sphere MQ將MQ消息流式傳輸到DAG中。但是，似乎沒有關於此事的IBM文檔。我知道它可能與ActiveMQ類似，我可能只需要傳入Websphere Jars，但我不知道從哪裏開始。 @Override public void populateDAG(DAG dag, Configuration conf

1熱度

1回答

創建新的Apache Apex項目時出現Maven原型錯誤

我正在關注有助於創建啓動項目的Apache Apex相關文檔。 https://apex.apache.org/docs/apex-3.4/apex_development_setup/#creating-new-apex-project 在執行maven的命令， @echo off @rem Script for creating a new application setlocal mv

3熱度

2回答

如何計算Apache Apex中運營商之間的網絡延遲

有沒有一種方法可以用來預測Apache Apex中兩個不同運營商之間的N/W延遲。在運營商將要使用的數據全部駐留在不同的機器上的情況下，這會增加運營商的延遲。這是如何計算的？

2熱度

1回答

添加輸入操作動態的運行Apache的Apex應用

是否有可能增加輸入操作員在運行的Apex應用不同的來源？例如：在生產環境中，我運行的頂點程序讀取來自輸入源的文本文件，我想用它的輸入操作相同的DAG添加卡夫卡源。

2熱度

3回答

可以在輸入操作DAG中的Apache中的Apex

頂點的所有實例中間使用說，DAG的第一家運營商應該是一個輸入操作。這個操作符可以出現在DAG的中間位置。考慮一個情況，我有數據要從數據庫中提取，基於剛剛由前一個運算符處理的一些數據，這意味着輸入運算符將位於DAG的某個位置中間。根據一個輸入操作者的定義是一個不具有任何輸入流。但是，如果使用連接器，它也會執行獲取數據的工作。那麼，如果我在DAG之間的某個地方提取數據，它會起作用嗎？

2熱度

2回答

試圖在YARN上運行Apache Apex的Yahoo Finance示例

我已經下載Apache Apex 3.5.0以及Malhar 3.5.0。我已成功啓動apex客戶端，並將雅虎財務演示示例提交給我們的YARN集羣（運行CDH 5.10）。羣集正在運行並正確配置（許多Spark和MR作業正在運行）。我看到我在YARN以及Apex cli中提交的作爲RUNNING的應用程序。然而，當我嘗試連接到應用程序主，我收到了404 org.apache.hadoop.ya

2熱度

3回答

在沒有DataTorrent RTS的情況下使用Apex

是否有可能在沒有DataTorrent RTS的情況下使用Apache Apex？看起來有可能，但我找不到任何有關安裝apex源代碼的任何教程（要運行，您需要以二進制形式輸入apex）。我看到Apex CLI在生成./engine/src/main/scripts/apex之後可用，但是也許有一些更簡單的方法比逐個構建它。

2熱度

2回答

如何使用Apex進行批處理？

如何使用Apache Apex創建批處理應用程序？我發現的所有示例都是流式應用程序，這意味着它們不會結束，我希望我的應用程序在處理完所有數據後關閉它。謝謝

1熱度

3回答

需要架構提示：數據複製到雲端+數據清理

我需要將客戶數據從幾個內部數據庫同步到雲中。第二步，客戶數據需要進行一些清理以刪除（不同類型的）重複項。根據清理的數據，我需要做一些數據分析。爲了實現這一目標，我正在尋找一種可用於開放源代碼的框架或雲解決方案。我看了一下Apache Apex和Apache Kafka，但我不確定這些解決方案是否正確。你能給我一個暗示你將用於這樣一個任務的框架嗎？