StreamingJobUtils

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total752 of 1,34243%64 of 11544%53891622861531
selectBackend(String)960%100%66202011
restoreSplitsToJob(Long)950%60%44222211
convertCertFile(long, Map)840%40%33151511
querySingleTableId(Long, String)640%40%339911
queryNextAvailableId(Long)590%40%338811
upsertChunkList(Long, String, List)520%20%22131311
createMetaTableIfNotExist()510%60%44121211
batchInsert(List)430%60%44101011
generateCreateTableCmds(String, DataSourceType, Map, Map)3821785%91765%71455301
buildConnectContext()380%n/a11111111
validateTvfSource(String, Map, String)28515%1150%1281001
deleteJobMeta(Long)210%n/a117711
resolveAndValidateSource(DataSourceType, Map, String, List)210%20%227711
execute(String)150%n/a115511
getLastSelectedBackendIndexAndUpdate()130%20%223311
getRemoteDbName(DataSourceType, Map)122970%1266%1311001
lambda$getColumns$2(String, List, Column)106085%31178%3821601
validateSource(DataSourceType, Map, String, List)80%20%223311
StreamingJobUtils()30%n/a111111
lambda$parseExcludeColumns$5(String)685%1150%120101
validateExcludeColumns(Set, String, List, List)60100%6100%040801
getJdbcClient(DataSourceType, Map)47100%n/a010801
getTableCreateProperties(Map)38100%1375%130701
parseExcludeColumns(Map, String)35100%2100%020801
getColumns(JdbcClient, String, String, List)20100%n/a010601
populateDefaultSourceProperties(DataSourceType, Map, String)16100%2100%020601
lambda$generateCreateTableCmds$1(Column)15100%n/a010201
lambda$getColumns$4(List, Column)13100%2100%020301
lambda$getColumns$3(List, Column)10100%2100%020101
static {...}10100%n/a010301
lambda$generateCreateTableCmds$0(Set, Column)9100%2100%020101