Spark Based 運算計價方式

此公式適用於Spark-sehll、PySpark、iPython NOtebook、Spark-Submit等以Spark做為運算引擎之程式

Spark Application的Total-CPU-Core-Hour為加總所有Executor的cpu-core-hour。而Executor的生存時間和Spark Application的生存時間是相同的。 $SU = \Bigg\{\sum_{i \in success}{AppDruation\times 1core} + \sum_{j\in Removed}{ExecutorDuration_j\times 1core}\Bigg\} \times 1.95$ B計畫購買了1000個SU；某次使用Spark運算，整個Spark Application總執行時間為5hr，此運算共使用5個Executors，其中二個Executor失敗被移除，這2個executor執行時間分別為1hr與2h。 $SU = ( 1h \times 1core + 2h \times 1core+ 5h \times 3core ) \times 1.95 = 35.1 SU$' ，故還剩 1000 – 35.1 = 964.9 SU