| Constructor and Description |
|---|
LogCleaner(Map<String,Object> stormConf,
WorkerLogs workerLogs,
DirectoryCleaner directoryCleaner,
Path logRootDir,
StormMetricsRegistry metricsRegistry)
Constuctor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
run()
Delete old log dirs for which the workers are no longer alive.
|
void |
start()
Start log cleanup thread.
|
public LogCleaner(Map<String,Object> stormConf, WorkerLogs workerLogs, DirectoryCleaner directoryCleaner, Path logRootDir, StormMetricsRegistry metricsRegistry)
Constuctor.
stormConf - configuration map for Storm clusterworkerLogs - WorkerLogs instancedirectoryCleaner - DirectoryCleaner instancelogRootDir - root log directorymetricsRegistry - The logviewer metrics registrypublic void start()
Start log cleanup thread.
public void close()
close in interface Closeableclose in interface AutoCloseableCopyright © 2021 The Apache Software Foundation. All rights reserved.