Java 类org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator 实例源码

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}

public void setSignalled(boolean isSignalled) {
  ((RMCommunicator) containerAllocator).setSignalled(isSignalled);
}

public void setShouldUnregister(boolean shouldUnregister) {
  ((RMCommunicator) containerAllocator).setShouldUnregister(shouldUnregister);
}

@Override
public long getLastHeartbeatTime() {
  return ((RMCommunicator) containerAllocator).getLastHeartbeatTime();
}

@Override
public void runOnNextHeartbeat(Runnable callback) {
  ((RMCommunicator) containerAllocator).runOnNextHeartbeat(callback);
}