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

YarnClusterClient.<init>介绍

[英]Create a new Flink on YARN cluster.
[中]

代码示例

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

@Override
  protected ClusterClient<ApplicationId> createYarnClusterClient(AbstractYarnClusterDescriptor descriptor, int numberTaskManagers, int slotsPerTaskManager, ApplicationReport report, Configuration flinkConfiguration, boolean perJobCluster) throws Exception {
    return new YarnClusterClient(
      descriptor,
      numberTaskManagers,
      slotsPerTaskManager,
      report,
      flinkConfiguration,
      perJobCluster);
  }
}

代码示例来源：origin: uber/AthenaX

@Override
protected ClusterClient<ApplicationId> createYarnClusterClient(
  AbstractYarnClusterDescriptor clusterDescriptor,
  int numberTaskManagers,
  int slotPerTaskManager,
  ApplicationReport applicationReport,
  Configuration configuration,
  boolean isNewlyCreatedCluster) throws Exception {
 return new YarnClusterClient(
   clusterDescriptor,
   numberTaskManagers,
   slotPerTaskManager,
   applicationReport,
   configuration,
   isNewlyCreatedCluster);
}

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

@Override
  protected ClusterClient<ApplicationId> createYarnClusterClient(AbstractYarnClusterDescriptor descriptor, int numberTaskManagers, int slotsPerTaskManager, ApplicationReport report, Configuration flinkConfiguration, boolean perJobCluster) throws Exception {
    return new YarnClusterClient(
      descriptor,
      numberTaskManagers,
      slotsPerTaskManager,
      report,
      flinkConfiguration,
      perJobCluster);
  }
}

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

@Override
  protected ClusterClient<ApplicationId> createYarnClusterClient(AbstractYarnClusterDescriptor descriptor, int numberTaskManagers, int slotsPerTaskManager, ApplicationReport report, Configuration flinkConfiguration, boolean perJobCluster) throws Exception {
    return new YarnClusterClient(
      descriptor,
      numberTaskManagers,
      slotsPerTaskManager,
      report,
      flinkConfiguration,
      perJobCluster);
  }
}