ignite

    1熱度

    1回答

    我試圖創建緩存(實際上幾乎是從示例代碼複製粘貼來了解它是如何工作的),並且只是寫入/讀取一些數據。我能夠開始點燃節點但當但在嘗試下面的堆棧跟蹤收到錯誤創建緩存: Exception in thread "main" class org.apache.ignite.IgniteException: Failed to instantiate Spring XML application contex

    1熱度

    1回答

    我已經用companyId作爲關鍵字定義了以下兩個類Person(帶PersonKey)和Company()。 PersonKey與公司Id親緣搭配。現在我正在試圖做SQL分佈式連接(Person.companyId = Company.companyId) on 2個節點連接成網格。我只重複了與單節點相同的連接。使用2個節點的分佈式連接,我應該獲得2倍的性能提升,但與單個節點相比,它表現得最差。

    3熱度

    2回答

    如何在多個線程嘗試訪問相同的Ignite實例時創建多個Ignite實例。 Ignite ignite = Ignition.start(「conf/example-ignite-config.xml」); 這裏我已經開始/創建了一個Ignite實例。但使用相同的XML我不得不創建多個實例沒有其他線程等待它得到自由。

    0熱度

    1回答

    我正在運行具有提供服務的各種節點的Apache Ignite集羣。每個節點被分配一個描述該節點正在提供的服務的特定服務組(定製節點屬性),例如,授權,付款... 其中一些服務正在使用Ignite緩存,但我希望這些服務特定的緩存僅部署在關聯的服務節點上。因此,我正在爲緩存配置添加節點篩選器: // configuration with custom attribute is provided at

    0熱度

    1回答

    如何在通過ignite.sh運行時爲Apache Ignite設置可用的最大堆內存?文檔似乎不涉及這個非常基本的任務。另外,如何確認設置實際上正在工作? 我讀過命令行選項-J可用於將JVM參數從ignite.sh傳遞給JVM進程,但無法找到它實際上正在工作的證據。例如,如果我開始點燃如下: bin/ignite.sh -v -J-Xmx2g 程序輸出以下消息: [09:13:42,422][I

    1熱度

    1回答

    我們需要跨多個會話共享RDD。我看到使用Java訪問訪問Spark數據集的Ignite RDD/Ignite SQL的選項。任何人都嘗試使用IgniteRDD/IgniteSQL使用Scala訪問Spark數據集。

    1熱度

    1回答

    這裏是我的代碼 public static void save(IgniteContext igniteContext, String cacheName, Dataset<Row> dataSet) { CacheConfiguration<BinaryObject, BinaryObject> cacheConfiguration = new CacheConfiguration<

    1熱度

    1回答

    工作以及我上傳約100萬在所有3 caches.while在點燃3緩存中的數據和總數據我在其上運行的查詢我得到了導致1和它產生下面的查詢計劃 SELECT DISTINCT A3.VAL2 AS __C0 FROM DPHAF.DPHAF A1 /* DPHAF.DPHAF.__SCAN_ */ /* WHERE (A1.VAL0 = 'dg~') AN

    1熱度

    1回答

    我們計劃將Apache Ignite用於我們的生產系統。目前我們認爲我們的內存總和不會超過1TB,但在接近未來的情況下,這個數字將會增加。 有沒有人有關於使用點火的當前生產系統的信息?我們將使用AWS w/s3來控制集羣。可能是RAM小於32G的服務器,以利用-XX:+UseCompressedOops。 一些問題包括: 集羣中的服務器數量。是否有一個我們不應超過的實際數字。 以RAM計算的總大小

    0熱度

    1回答

    我使用了兩個節點,一個是從IDE(Intellij IDEA)啓動計算,另一個是已經在控制檯啓動(啓用遠程調試)的另一個節點。我正在從IDE進行調試。 我沒有使用peerClassLoading,我已經將jar放在控制檯節點的庫中。 有一行代碼:System.out.println(x); - 在兩種打印都很好。但以下幾行: getPrintWriter().println(x); getPri