public class DefaultBlockMaster.WorkerRegisterStreamGCExecutor extends Object implements HeartbeatExecutor
Constructor and Description |
---|
WorkerRegisterStreamGCExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Cleans up any resources used by the heartbeat executor.
|
void |
heartbeat(long timeLimitMs)
Implements the heartbeat logic.
|
public void heartbeat(long timeLimitMs)
HeartbeatExecutor
heartbeat
in interface HeartbeatExecutor
timeLimitMs
- time limit in milliseconds this heartbeat should not exceed when runningpublic void close()
HeartbeatExecutor
close
in interface HeartbeatExecutor
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2023. All Rights Reserved.