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);
}