org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver.setConnect()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 09:53:45 26 4

int bitPort = config.getInt(DrillOnYarnConfig.DRILLBIT_BIT_PORT);
ZKClusterCoordinatorDriver driver = new ZKClusterCoordinatorDriver()
  .setConnect(zkConnect, zkRoot, clusterId)
  .setFailureTimoutMs(failureTimeoutMs)
  .setRetryCount(retryCount)

/**
 * Basic setup: start a ZK and verify that the initial endpoint list is empty.
 * Also validates the basics of the test setup (mock server, etc.)
 *
 * @throws Exception
 */
@Test
public void testBasics() throws Exception {
 try (TestingServer server = new TestingServer()) {
  server.start();
  String connStr = server.getConnectString();
  ZKClusterCoordinatorDriver driver = new ZKClusterCoordinatorDriver()
    .setConnect(connStr, "drill", "drillbits").build();
  assertTrue(driver.getInitialEndpoints().isEmpty());
  driver.close();
  server.stop();
 }
}

String connStr = server.getConnectString();
ZKClusterCoordinatorDriver driver = new ZKClusterCoordinatorDriver()
  .setConnect(connStr, TEST_ZK_ROOT, TEST_CLUSTER_ID).build();
   .setConnect(connStr, TEST_ZK_ROOT, TEST_CLUSTER_ID).build();
   .setConnect(connStr, TEST_ZK_ROOT, PROBE_CLUSTER_ID).build();
   .setConnect(connStr, PROBE_ZK_ROOT, TEST_CLUSTER_ID).build();
   .setConnect(connStr, TEST_ZK_ROOT, TEST_CLUSTER_ID).build();

.setConnect(connStr, ZK_ROOT, CLUSTER_ID).build();
List<DrillbitEndpoint> bits = driver.getInitialEndpoints();
assertEquals(1, bits.size());

.setConnect(connStr, ZK_ROOT, CLUSTER_ID)
  .setPorts(TEST_USER_PORT, TEST_CONTROL_PORT, TEST_DATA_PORT).build();
ZKRegistry registry = new ZKRegistry(driver);

26 4 0

• apache-drill - Apache Drill 如何处理大结果集？

  假设您将 Drill 连接到两个独立的数据库，并且运行一个查询，从每个数据库中提取大量数据，然后进行联接。 Drill 如何处理这个问题而不引发内存不足错误？这是假设您请求的数据超出了 Drill 可

• apache-drill - Apache Drill 一次支持多个查询吗？

  我想一次运行选择 Sql Server 查询。我在嵌入式模式下使用 Drill。 select * from ..; select * from ..; 例子:- select * from SqlS

• apache-drill - Apache 元模型与 Apache Drill

  Apache MetaModel 是一个数据访问框架，它为发现、探索和查询不同类型的数据源提供了一个通用接口(interface)。 Apache Drill 是一种无架构的 SQL 查询引擎，它通过

• apache-drill - Apache Drill 不使用最大 RAM

  我在具有 16GB 内存的 ubuntu 机器上本地运行 apacherill 1.0(然后在 1.4 上)。当我使用一个非常大的制表符分隔文件(5200 万行，7GB)并执行 Select dist

• apache-drill - 如何在 apache drill 中以编程方式添加更多存储插件？

  我尝试了钻取 JDBC 驱动程序以编程方式进行查询。 代码的有用部分: Connection conn = new Driver().connect("jdbc:drill:zk=local", ge

• java - Apache Drill - 以嵌入式模式连接到 Drill [java]

  我想连接到 Drill by Java 应用程序，到目前为止，我一直在尝试使用 JDBC 来完成它，我正在使用 https://github.com/vicenteg/DrillJDBCExample

• apache-drill - Apache Drill 中的 WHERE filename 对所有文件进行全面扫描

  select distinct filename from dfs.contoso.`folder/CSVs/` > 2021-01.csv > 2021-02.csv > ... 或 select

• apache-drill - 无法使用 apache drill 查询 RDBMS

  使用 apache drill 1.2，我们可以查询 RDBMS 数据。在这里查看更多信息:https://drill.apache.org/blog/2015/10/16/drill-1.2-rel

• apache-drill - 将 Drill 查询输出写入 csv(或其他格式)

  我在嵌入模式下使用drill，除了复制和粘贴之外，我不知道如何保存查询输出。 最佳答案 如果您使用 sqlline，则可以创建一个 CSV 格式的新表，如下所示: use dfs.tmp; alter

• apache-drill - Apache Drill 新手 : Cannot see Web Console

  我在 ubuntu 14.04 64 机器上下载了 apache-drill-1.2.0。提取 tar.zip 内容，转到 bin 文件夹并运行钻取。 现在我尝试打开:http://localhost

• apache-drill - Apache Drill 可以读取 Apache ORC 文件格式吗？

  Apache Drill 可以读取 ORC 文件吗？ 最佳答案 这个答案是由用户 agirish 在 Apache Drill 邮件列表中发布的。复制到这里是为了对这个社区有用。 Drill can

• apache-drill - 在 Windows 10 上以嵌入式模式启动 Apache Drill 时出错

  我正在尝试在 Windows 10 x64(使用 Oracle JVM 1.8.0_131)上以嵌入式模式启动 Apache Drill 1.10。启动命令时 sqlline.bat -u "jdbc

• apache-drill - 运行 Apache Drill 需要 Java 1.7 或更高版本

  当我打字 $ drillbit.sh start 它向我展示了这个错误: ERROR: Java 1.7 or later is required to run Apache Drill. 虽然我有最

• Apache Drill 模拟

  我正在尝试在我们的 Drill (1.6.0) 系统上构建安全性。我设法让安全用户身份验证工作(如文档中所述的 JPam)，但模拟似乎不起作用。它似乎通过管理员用户执行和获取，而不管谁通过 ODBC

• apache-drill - 如何查询数组？

  我在 drill 中有一个这样的对象: {MyFruit: [{name:Mike, age:10},{name:Jacob,age:9},{name:William, age:6}]} 我可以通过以

• hadoop - 基于时间的目录结构Apache Drill

  我有按日期和时间组织的CSV文件，如下所示 logs/YYYY/MM/DD/CSV files... 我已设置Apache Drill在这些CSV文件之上执行SQL查询。由于有很多CSV文件；文件的组

• apache-drill - 如何以分布式方式在本地启动drillbit？

  我下载了 Apache Drill v1.8，编辑了 conf/drill-override.conf 以进行以下更改: drill.exec: { cluster-id: "drillbits1

• apache-drill - 如何以分布式方式在本地启动drillbit？

  我下载了 Apache Drill v1.8，编辑了 conf/drill-override.conf 以进行以下更改: drill.exec: { cluster-id: "drillbits1

• emacs - 如何安装 org-drill？

  我是 Emacs 新手，完成了 Emacs 和基本的 org-mode 教程。 现在我想安装 org-drill。以下是我在 Emacs 上安装 org-drill 的失败尝试。 来自 http://

• json - Apache Drill:从Json数据中选择时创建表错误

  下面的命令运行正常。 SELECT TO_TIMESTAMP(`ts`,'yyyyMMddHHmmss') FROM dfs.tmp`/mapr/my.cluster.com/hive/cpf_sal