spark JavaRDD T可以是自定義類(lèi)型嗎？有沒(méi)有例子？這是一個(gè)常見(jiàn)問(wèn)題。<T>定義一個(gè)類(lèi)型并使用它。spark是怎么區(qū)分transformer和action算子的？在我看來(lái)，spark

spark JavaRDD T可以是自定義類(lèi)型嗎？有沒(méi)有例子？

這是一個(gè)常見(jiàn)問(wèn)題。<T>定義一個(gè)類(lèi)型并使用它。

spark是怎么區(qū)分transformer和action算子的？

在我看來(lái)，spark編程中的action操作符充當(dāng)觸發(fā)器來(lái)觸發(fā)上一個(gè)轉(zhuǎn)換操作符。轉(zhuǎn)換操作具有延遲加載的特性。定義操作后，不會(huì)立即加載它。只有當(dāng)一個(gè)動(dòng)作操作符被執(zhí)行時(shí)，所有先前的轉(zhuǎn)換操作符才會(huì)被執(zhí)行。下面的代碼中列出了常見(jiàn)的操作操作符：（Java版本）包星火研究.core導(dǎo)入java.util.Arrays數(shù)組導(dǎo)入java.util.List導(dǎo)入java.util.Mapimport文件org.apache.spark網(wǎng)站.SparkConf導(dǎo)入org.apache.spark網(wǎng)站. api.java.javapairdd文件導(dǎo)入org.apache.spark網(wǎng)站. api.java.JavaRDD文件導(dǎo)入org.apache.spark網(wǎng)站. api.java.JavaSparkContext導(dǎo)入org.apache.spark網(wǎng)站. api.java.function函數(shù).函數(shù)導(dǎo)入org.apache.spark網(wǎng)站. api.java.function函數(shù).