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

YarnIntraNonHaMasterServices.enter介绍

暂无

代码示例

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

@Override
public LeaderElectionService getResourceManagerLeaderElectionService() {
  enter();
  try {
    return resourceManagerLeaderElectionService;
  }
  finally {
    exit();
  }
}

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

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress) {
  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 LeaderElectionService getJobManagerLeaderElectionService(JobID jobID) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  finally {
    exit();
  }
}

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

@Override
public LeaderElectionService getWebMonitorLeaderElectionService() {
  enter();
  try {
    throw new UnsupportedOperationException();
  }
  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 getDispatcherLeaderElectionService() {
  enter();
  try {
    return dispatcherLeaderElectionService;
  } finally {
    exit();
  }
}

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

@Override
public LeaderRetrievalService getResourceManagerLeaderRetriever() {
  enter();
  try {
    return resourceManagerLeaderElectionService.createLeaderRetrievalService();
  }
  finally {
    exit();
  }
}

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

@Override
public LeaderRetrievalService getDispatcherLeaderRetriever() {
  enter();
  try {
    return dispatcherLeaderElectionService.createLeaderRetrievalService();
  } finally {
    exit();
  }
}

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

@Override
public LeaderElectionService getResourceManagerLeaderElectionService() {
  enter();
  try {
    return resourceManagerLeaderElectionService;
  }
  finally {
    exit();
  }
}

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

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

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

@Override
public LeaderElectionService getWebMonitorLeaderElectionService() {
  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

@Override
public LeaderElectionService getDispatcherLeaderElectionService() {
  enter();
  try {
    return dispatcherLeaderElectionService;
  } finally {
    exit();
  }
}

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

@Override
public LeaderRetrievalService getJobManagerLeaderRetriever(JobID jobID, String defaultJobManagerAddress) {
  enter();
  try {
    throw new UnsupportedOperationException("needs refactoring to accept default address");
  }
  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

@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 {
    return dispatcherLeaderElectionService;
  } 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 LeaderRetrievalService getResourceManagerLeaderRetriever() {
  enter();
  try {
    return resourceManagerLeaderElectionService.createLeaderRetrievalService();
  }
  finally {
    exit();
  }
}