我正在編寫一個後端應用程序，該應用程序應該接收來自客戶端的請求並使用點火緩存執行一些操作。問題是我需要低延遲響應時間並重新創建客戶端節點以執行某些操作，而緩存是完全不可接受的。 通常在應用程序啓動時創建Ignite客戶機節點一次，然後在後端接收到來自需要使用Ignite高速緩存的一些操作的客戶機請求時使用它。我的意思是這樣的： public class Handler{
private
我實現的是： val sparkConf = new SparkConf().setAppName(「SharedRDD」).setMaster(「local」)
val sc = SparkContext.getOrCreate(sparkConf)
val sparkRDD = sc.wholeTextFiles("sample.csv", 10)
這RDD由IgniteContext
嗨，我正在閱讀項目中的一些代碼，我剛開始工作，並看到一些類似這樣的代碼，我無法理解。 public class A implements Ignite {
protected Ignite ignite;
.......
protected void checkIgnite() {
......
}
@Override
pu