Java源码示例:org.apache.flink.runtime.heartbeat.HeartbeatTarget
示例1
@Override
public void monitorTarget(ResourceID resourceID, HeartbeatTarget<O> heartbeatTarget) {
super.monitorTarget(resourceID, heartbeatTarget);
monitoredTargets.offer(resourceID);
}
示例2
@Override
public void monitorTarget(ResourceID resourceID, HeartbeatTarget<O> heartbeatTarget) {
super.monitorTarget(resourceID, heartbeatTarget);
monitoredTargets.offer(resourceID);
}
示例3
@Override
public void monitorTarget(ResourceID resourceID, HeartbeatTarget<O> heartbeatTarget) {
super.monitorTarget(resourceID, heartbeatTarget);
monitoredTargets.offer(resourceID);
}