本文整理了Java中org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices.enter()方法的一些代码示例，展示了YarnPreConfiguredMasterNonHaServices.enter()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YarnPreConfiguredMasterNonHaServices.enter()方法的具体详情如下：
包路径：org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices
类名称：YarnPreConfiguredMasterNonHaServices
方法名：enter

YarnPreConfiguredMasterNonHaServices.enter介绍

暂无

代码示例

代码示例来源：origin: apache/flink

@Override
public LeaderElectionService getDispatcherLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException("Not supported on the TaskManager side");
  } finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderElectionService getWebMonitorLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException();
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderElectionService getResourceManagerLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException("Not supported on the TaskManager side");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderElectionService getJobManagerLeaderElectionService(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
  public LeaderRetrievalService getWebMonitorLeaderRetriever() {
    enter();
    try {
      throw new UnsupportedOperationException();
    }
    finally {
      exit();
    }
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getDispatcherLeaderRetriever() {
  enter();
  try {
    return new StandaloneLeaderRetrievalService(dispatcherRpcUrl, DEFAULT_LEADER_ID);
  } finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getResourceManagerLeaderRetriever() {
  enter();
  try {
    return new StandaloneLeaderRetrievalService(resourceManagerRpcUrl, DEFAULT_LEADER_ID);
  }
  finally {
    exit();
  }
}

代码示例来源：origin: apache/flink

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress) {
  enter();
  try {
    return new StandaloneLeaderRetrievalService(defaultJobManagerAddress, DEFAULT_LEADER_ID);
  } finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
  public LeaderRetrievalService getWebMonitorLeaderRetriever() {
    enter();
    try {
      throw new UnsupportedOperationException();
    }
    finally {
      exit();
    }
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderElectionService getDispatcherLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException("Not supported on the TaskManager side");
  } finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
  public LeaderRetrievalService getWebMonitorLeaderRetriever() {
    enter();
    try {
      throw new UnsupportedOperationException();
    }
    finally {
      exit();
    }
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderElectionService getJobManagerLeaderElectionService(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderElectionService getJobManagerLeaderElectionService(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderElectionService getResourceManagerLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException("Not supported on the TaskManager side");
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderRetrievalService getDispatcherLeaderRetriever() {
  enter();
  try {
    return new StandaloneLeaderRetrievalService(dispatcherRpcUrl, DEFAULT_LEADER_ID);
  } finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
public LeaderRetrievalService getResourceManagerLeaderRetriever() {
  enter();
  try {
    return new StandaloneLeaderRetrievalService(resourceManagerRpcUrl, DEFAULT_LEADER_ID);
  }
  finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderRetrievalService getDispatcherLeaderRetriever() {
  enter();
  try {
    return new StandaloneLeaderRetrievalService(dispatcherRpcUrl, DEFAULT_LEADER_ID);
  } finally {
    exit();
  }
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress) {
  enter();
  try {
    return new StandaloneLeaderRetrievalService(defaultJobManagerAddress, DEFAULT_LEADER_ID);
  } finally {
    exit();
  }
}