StateDirectory

Source file "org/apache/kafka/streams/processor/internals/StateDirectory.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,297 of 1,2970%154 of 1540%1111112712713434
StateDirectory(StreamsConfig, Time, boolean, boolean)1330%160%99252511
cleanStateAndTaskDirectoriesCalledByUser()1260%80%55242411
cleanRemovedTasksCalledByCleanerThread(long)1060%80%55191911
clean()950%80%55232311
maybeCleanEmptyNamedTopologyDirs(boolean)910%120%77202011
getOrCreateDirectoryForTask(TaskId)870%140%88171711
initializeProcessId()800%80%55222211
listTaskDirectories(FileFilter)680%120%77161611
lock(TaskId)520%80%55141411
configurePermissions(File)500%40%33141411
globalStateDir()500%100%669911
taskDirIsEmpty(File)490%100%66101011
lockStateDirectory()470%20%228811
close()370%40%33121211
getTaskDirectoryParentName(TaskId)320%40%336611
unlock(TaskId)240%40%335511
lambda$listNonEmptyTaskDirectories$2(File)190%60%443311
lambda$listNamedTopologyDirs$6(File)140%40%331111
lambda$listAllTaskDirectories$3(File)130%40%331111
lambda$maybeCleanEmptyNamedTopologyDirs$1(File)130%40%331111
cleanRemovedTasks(long)120%n/a115511
listNamedTopologyDirs()120%20%222211
logPrefix()100%n/a111111
static {...}100%n/a113311
lambda$taskDirIsEmpty$0(File)90%20%221111
checkpointFileFor(TaskId)80%n/a111111
directoryForTaskIsEmpty(TaskId)80%n/a112211
parseNamedTopologyFromDirectory(String)80%n/a111111
StateDirectory(StreamsConfig, Time, boolean)70%n/a112211
tryLock(FileChannel)60%n/a113311
lambda$listTaskDirectories$5(File)60%n/a111111
lambda$listTaskDirectories$4(String, File)60%n/a111111
listNonEmptyTaskDirectories()50%n/a111111
listAllTaskDirectories()40%n/a111111