createRecordReader(Configuration, Properties, HudiSplit, List) |  | 0% | | n/a | 1 | 1 | 20 | 20 | 1 | 1 |
createRealtimeRecordCursor(HdfsEnvironment, ConnectorSession, Properties, HudiSplit, List, ZoneId, TypeManager) |  | 0% | | n/a | 1 | 1 | 15 | 15 | 1 | 1 |
refineCompressionCodecs(Configuration) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
createInputFormat(Configuration, String) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
lambda$createRealtimeRecordCursor$0(Configuration, Properties, HudiSplit, List, Path, HudiFile, ZoneId, TypeManager) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getHudiBaseFile(HudiSplit) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
join(List, Function) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isRegularColumn(HudiColumnHandle) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$createRecordReader$1(JobConf, Properties, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createRecordReader$2(HudiFile) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |