org.apache.drill.exec.ZookeeperTestUtil类的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 09:58:33 25 4

@BeforeClass
public static void initCluster() throws Exception {
 ZookeeperTestUtil.setJaasTestConfigFile();

@BeforeClass
public static void initKafka() throws Exception {
 synchronized (TestKafkaSuit.class) {
  if (initCount.get() == 0) {
   ZookeeperTestUtil.setZookeeperSaslTestConfigProps();
   System.setProperty(JaasUtils.JAVA_LOGIN_CONFIG_PARAM, ClassLoader.getSystemResource(LOGIN_CONF_RESOURCE_PATHNAME).getFile());
   embeddedKafkaCluster = new EmbeddedKafkaCluster();
   Properties topicProps = new Properties();
   zkClient = new ZkClient(embeddedKafkaCluster.getZkServer().getConnectionString(), SESSION_TIMEOUT, CONN_TIMEOUT, ZKStringSerializer$.MODULE$);
   ZkUtils zkUtils = new ZkUtils(zkClient, new ZkConnection(embeddedKafkaCluster.getZkServer().getConnectionString()), false);
   AdminUtils.createTopic(zkUtils, TestQueryConstants.JSON_TOPIC, 1, 1, topicProps, RackAwareMode.Disabled$.MODULE$);
   org.apache.kafka.common.requests.MetadataResponse.TopicMetadata fetchTopicMetadataFromZk = AdminUtils
     .fetchTopicMetadataFromZk(TestQueryConstants.JSON_TOPIC, zkUtils);
   logger.info("Topic Metadata: " + fetchTopicMetadataFromZk);
   KafkaMessageGenerator generator = new KafkaMessageGenerator(embeddedKafkaCluster.getKafkaBrokerList(),
     StringSerializer.class);
   generator.populateJsonMsgIntoKafka(TestQueryConstants.JSON_TOPIC, NUM_JSON_MSG);
  }
  initCount.incrementAndGet();
  runningSuite = true;
 }
 logger.info("Initialized Embedded Zookeeper and Kafka");
}

25 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