com.dremio.service.coordinator.zk.ZKClusterCoordinator.()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-20 06:40:31 54 4

public int submitQuery(String planLocation, String queryString, String type, String zkQuorum, boolean local, int bits, String format, int width) throws Exception {
 SabotConfig config = SabotConfig.create();
 Preconditions.checkArgument(!local, "Can only run remote.");
 DremioClient client = null;
 Preconditions.checkArgument(!(planLocation == null && queryString == null), "Must provide either query file or query string");
 Preconditions.checkArgument(!(planLocation != null && queryString != null), "Must provide either query file or query string, not both");
 try {
  ZKClusterCoordinator clusterCoordinator = new ZKClusterCoordinator(config, zkQuorum);
  clusterCoordinator.start();
  client = new DremioClient(config, clusterCoordinator);
  client.connect();
  String plan;
  if (queryString == null) {
   plan = Charsets.UTF_8.decode(ByteBuffer.wrap(Files.readAllBytes(Paths.get(planLocation)))).toString();
  } else {
   plan = queryString;
  }
  return submitQuery(client, plan, type, format, width);
 } catch(Throwable th) {
  System.err.println("Query Failed due to : " + th.getMessage());
  return -1;
 } finally {
  if (client != null) {
   client.close();
  }
 }
}

if (clusterCoordinator == null) {
 try {
  clusterCoordinator = new ZKClusterCoordinator(this.config, connect);
  clusterCoordinator.start();
 } catch (Exception e) {

@Test
public void testGivingUpLeadership() throws Exception {
 try(ZKClusterCoordinator coordinator = new ZKClusterCoordinator(
  DEFAULT_SABOT_CONFIG,
  String.format("%s/dremio/test/test-cluster-id", zooKeeperServer.getConnectString()))

coord = new ZKClusterCoordinator(config.getSabotConfig(), portProvider);
} catch (IOException e) {
 throw new RuntimeException("Cannot instantiate the ZooKeeper cluster coordinator", e);

@Test
public void testElectionsWithRegistration() throws Exception {
 try(ZKClusterCoordinator coordinator = new ZKClusterCoordinator(
  DEFAULT_SABOT_CONFIG,
  String.format("%s/dremio/test/test-cluster-id", zooKeeperServer.getConnectString()))

54 4 0

• com.dremio.provision.yarn.YarnController类的使用及代码示例

  本文整理了Java中com.dremio.provision.yarn.YarnController类的一些代码示例，展示了YarnController类的具体用法。这些代码示例主要来源于Github

• com.dremio.provision.yarn.YarnTwillLogHandler类的使用及代码示例

  本文整理了Java中com.dremio.provision.yarn.YarnTwillLogHandler类的一些代码示例，展示了YarnTwillLogHandler类的具体用法。这些代码示例主

• com.dremio.dac.daemon.ZkServer类的使用及代码示例

  本文整理了Java中com.dremio.dac.daemon.ZkServer类的一些代码示例，展示了ZkServer类的具体用法。这些代码示例主要来源于Github/Stackoverflow/M

• com.dremio.service.coordinator.zk.ZKClusterCoordinator类的使用及代码示例

  本文整理了Java中com.dremio.service.coordinator.zk.ZKClusterCoordinator类的一些代码示例，展示了ZKClusterCoordinator类的具体

• com.dremio.service.coordinator.zk.ZKClusterClient类的使用及代码示例

  本文整理了Java中com.dremio.service.coordinator.zk.ZKClusterClient类的一些代码示例，展示了ZKClusterClient类的具体用法。这些代码示例主

• apache-spark - 数据集中的分割数超过数据集分割限制，Dremio + Hive + Spark

  我们有一个由Hadoop + Hive + Spark + Dremio组成的堆栈，因为Spark为一个Hive分区写入多个HDFS文件(取决于工作人员)，由于超出了HDFS文件数限制，因此在查询表时

• com.dremio.provision.yarn.YarnController.getTwillService()方法的使用及代码示例

  本文整理了Java中com.dremio.provision.yarn.YarnController.getTwillService()方法的一些代码示例，展示了YarnController.getT

• com.dremio.provision.yarn.YarnController.startCluster()方法的使用及代码示例

  本文整理了Java中com.dremio.provision.yarn.YarnController.startCluster()方法的一些代码示例，展示了YarnController.startCl

• com.dremio.provision.yarn.YarnController.prepareCommandOptions()方法的使用及代码示例

  本文整理了Java中com.dremio.provision.yarn.YarnController.prepareCommandOptions()方法的一些代码示例，展示了YarnControlle

• com.dremio.provision.yarn.YarnController.()方法的使用及代码示例

  本文整理了Java中com.dremio.provision.yarn.YarnController.()方法的一些代码示例，展示了YarnController.()的具体用法。这些代码示例主要来源于

• com.dremio.provision.yarn.YarnTwillLogHandler.()方法的使用及代码示例

  本文整理了Java中com.dremio.provision.yarn.YarnTwillLogHandler.()方法的一些代码示例，展示了YarnTwillLogHandler.()的具体用法。这

• com.dremio.dac.daemon.ZkServer.()方法的使用及代码示例

  本文整理了Java中com.dremio.dac.daemon.ZkServer.()方法的一些代码示例，展示了ZkServer.()的具体用法。这些代码示例主要来源于Github/Stackover

• com.dremio.dac.daemon.ZkServer.getPort()方法的使用及代码示例

  本文整理了Java中com.dremio.dac.daemon.ZkServer.getPort()方法的一些代码示例，展示了ZkServer.getPort()的具体用法。这些代码示例主要来源于Gi

• com.dremio.service.coordinator.zk.ZKClusterCoordinator.()方法的使用及代码示例

  本文整理了Java中com.dremio.service.coordinator.zk.ZKClusterCoordinator.()方法的一些代码示例，展示了ZKClusterCoordinator

• com.dremio.service.coordinator.zk.ZKClusterCoordinator.start()方法的使用及代码示例

  本文整理了Java中com.dremio.service.coordinator.zk.ZKClusterCoordinator.start()方法的一些代码示例，展示了ZKClusterCoordi

• com.dremio.service.coordinator.zk.ZKClusterClient.joinElection()方法的使用及代码示例

  本文整理了Java中com.dremio.service.coordinator.zk.ZKClusterClient.joinElection()方法的一些代码示例，展示了ZKClusterClie

• com.dremio.service.coordinator.zk.ZKClusterClient.start()方法的使用及代码示例

  本文整理了Java中com.dremio.service.coordinator.zk.ZKClusterClient.start()方法的一些代码示例，展示了ZKClusterClient.star

• com.dremio.service.coordinator.zk.ZKClusterClient.newServiceSet()方法的使用及代码示例

  本文整理了Java中com.dremio.service.coordinator.zk.ZKClusterClient.newServiceSet()方法的一些代码示例，展示了ZKClusterCli