@NotThreadSafe public class CommandHandlingExecutor extends Object implements HeartbeatExecutor
Constructor and Description |
---|
CommandHandlingExecutor(JobServerContext jobServerContext,
TaskExecutorManager taskExecutorManager,
JobMasterClient masterClient,
WorkerNetAddress workerNetAddress)
Creates a new instance of
CommandHandlingExecutor . |
Modifier and Type | Method and Description |
---|---|
void |
close()
Cleans up any resources used by the heartbeat executor.
|
void |
heartbeat()
Implements the heartbeat logic.
|
public CommandHandlingExecutor(JobServerContext jobServerContext, TaskExecutorManager taskExecutorManager, JobMasterClient masterClient, WorkerNetAddress workerNetAddress)
CommandHandlingExecutor
.jobServerContext
- the job worker's context used to execute taskstaskExecutorManager
- the TaskExecutorManager
masterClient
- the JobMasterClient
workerNetAddress
- the connection info for this workerpublic void heartbeat()
HeartbeatExecutor
heartbeat
in interface HeartbeatExecutor
public void close()
HeartbeatExecutor
close
in interface HeartbeatExecutor
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2023. All Rights Reserved.