HudiLocalEngineContext

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total180 of 1800%0 of 0n/a282839392828
mapToPairAndReduceByKey(List, SerializablePairFunction, SerializableBiFunction, int)200%n/a114411
mapPartitionsToPairAndReduceByKey(Stream, SerializablePairFlatMapFunction, SerializableBiFunction, int)200%n/a114411
reduceByKey(List, SerializableBiFunction, int)190%n/a115511
lambda$mapPartitionsToPairAndReduceByKey$3(SerializableBiFunction, Map.Entry)170%n/a112211
mapToPair(List, SerializablePairFunction, Integer)120%n/a112211
map(List, SerializableFunction, int)110%n/a111111
flatMap(List, SerializableFunction, int)110%n/a112211
lambda$reduceByKey$6(SerializableBiFunction, List)100%n/a113311
lambda$mapToPairAndReduceByKey$2(SerializableBiFunction, List)90%n/a112211
HudiLocalEngineContext(StorageConfiguration)70%n/a112211
foreach(List, SerializableConsumer, int)60%n/a112211
HudiLocalEngineContext(StorageConfiguration, TaskContextSupplier)50%n/a112211
emptyHoodieData()30%n/a111111
parallelize(List, int)30%n/a111111
lambda$reduceByKey$5(Pair)30%n/a111111
lambda$reduceByKey$4(Pair)30%n/a111111
lambda$mapToPairAndReduceByKey$1(Pair)30%n/a111111
lambda$mapToPairAndReduceByKey$0(Pair)30%n/a111111
newAccumulator()20%n/a111111
getProperty(EngineProperty)20%n/a111111
getCachedDataIds(HoodieData.HoodieDataCacheKey)20%n/a111111
removeCachedDataIds(HoodieData.HoodieDataCacheKey)20%n/a111111
lambda$mapToPair$7(Object, Object)20%n/a111111
setProperty(EngineProperty, String)10%n/a111111
setJobStatus(String, String)10%n/a111111
putCachedDataIds(HoodieData.HoodieDataCacheKey, int[])10%n/a111111
cancelJob(String)10%n/a111111
cancelAllJobs()10%n/a111111