mapToPairAndReduceByKey(List, SerializablePairFunction, SerializableBiFunction, int) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
mapPartitionsToPairAndReduceByKey(Stream, SerializablePairFlatMapFunction, SerializableBiFunction, int) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
reduceByKey(List, SerializableBiFunction, int) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$mapPartitionsToPairAndReduceByKey$3(SerializableBiFunction, Map.Entry) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
mapToPair(List, SerializablePairFunction, Integer) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
map(List, SerializableFunction, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
flatMap(List, SerializableFunction, int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$reduceByKey$6(SerializableBiFunction, List) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$mapToPairAndReduceByKey$2(SerializableBiFunction, List) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
HudiLocalEngineContext(StorageConfiguration) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
foreach(List, SerializableConsumer, int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
HudiLocalEngineContext(StorageConfiguration, TaskContextSupplier) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
emptyHoodieData() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
parallelize(List, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$reduceByKey$5(Pair) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$reduceByKey$4(Pair) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$mapToPairAndReduceByKey$1(Pair) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$mapToPairAndReduceByKey$0(Pair) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
newAccumulator() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getProperty(EngineProperty) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCachedDataIds(HoodieData.HoodieDataCacheKey) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
removeCachedDataIds(HoodieData.HoodieDataCacheKey) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$mapToPair$7(Object, Object) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setProperty(EngineProperty, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setJobStatus(String, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
putCachedDataIds(HoodieData.HoodieDataCacheKey, int[]) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
cancelJob(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
cancelAllJobs() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |