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

QueryRunner.installPlugin介绍

暂无

代码示例

代码示例来源：origin: prestosql/presto

public static void installKafkaPlugin(EmbeddedKafka embeddedKafka, QueryRunner queryRunner, Map<SchemaTableName, KafkaTopicDescription> topicDescriptions)
{
  KafkaPlugin kafkaPlugin = new KafkaPlugin();
  kafkaPlugin.setTableDescriptionSupplier(() -> topicDescriptions);
  queryRunner.installPlugin(kafkaPlugin);
  Map<String, String> kafkaConfig = ImmutableMap.of(
      "kafka.nodes", embeddedKafka.getConnectString(),
      "kafka.table-names", Joiner.on(",").join(topicDescriptions.keySet()),
      "kafka.connect-timeout", "120s",
      "kafka.default-schema", "default");
  queryRunner.createCatalog("kafka", "kafka", kafkaConfig);
}

代码示例来源：origin: prestosql/presto

public static void installRedisPlugin(EmbeddedRedis embeddedRedis, QueryRunner queryRunner, Map<SchemaTableName, RedisTableDescription> tableDescriptions)
{
  RedisPlugin redisPlugin = new RedisPlugin();
  redisPlugin.setTableDescriptionSupplier(() -> tableDescriptions);
  queryRunner.installPlugin(redisPlugin);
  Map<String, String> redisConfig = ImmutableMap.of(
      "redis.nodes", embeddedRedis.getConnectString() + ":" + embeddedRedis.getPort(),
      "redis.table-names", Joiner.on(",").join(tableDescriptions.keySet()),
      "redis.default-schema", "default",
      "redis.hide-internal-columns", "true",
      "redis.key-prefix-schema-table", "true");
  queryRunner.createCatalog("redis", "redis", redisConfig);
}

代码示例来源：origin: prestosql/presto

@BeforeClass
public void setUp()
{
  metadata = new TestMetadata();
  getQueryRunner().installPlugin(new TestPlugin(metadata));
  getQueryRunner().installPlugin(new TpchPlugin());
  getQueryRunner().createCatalog("test", "test", ImmutableMap.of());
  getQueryRunner().createCatalog("tpch", "tpch", ImmutableMap.of());
}

代码示例来源：origin: prestosql/presto

@BeforeMethod
public void setUp()
    throws Exception
{
  SessionBuilder sessionBuilder = testSessionBuilder();
  generatedEvents = new EventsBuilder();
  queryRunner = DistributedQueryRunner.builder(sessionBuilder.build())
      .setExtraProperties(ImmutableMap.of("testing-warning-collector.preloaded-warnings", String.valueOf(TEST_WARNINGS)))
      .setNodeCount(1)
      .build();
  queryRunner.installPlugin(new TestingEventListenerPlugin(generatedEvents));
  generatedEvents.initialize(EXPECTED_EVENTS);
}

代码示例来源：origin: prestosql/presto

private static void installKuduConnector(QueryRunner runner, String schema)
{
  String masterAddresses = System.getProperty("kudu.client.master-addresses", "localhost:7051");
  Map<String, String> properties;
  if (!isSchemaEmulationEnabled()) {
    properties = ImmutableMap.of(
        "kudu.schema-emulation.enabled", "false",
        "kudu.client.master-addresses", masterAddresses);
  }
  else {
    properties = ImmutableMap.of(
        "kudu.schema-emulation.enabled", "true",
        "kudu.schema-emulation.prefix", getSchemaEmulationPrefix(),
        "kudu.client.master-addresses", masterAddresses);
  }
  runner.installPlugin(new KuduPlugin());
  runner.createCatalog("kudu", "kudu", properties);
  if (isSchemaEmulationEnabled()) {
    runner.execute("DROP SCHEMA IF EXISTS " + schema);
    runner.execute("CREATE SCHEMA " + schema);
  }
}

代码示例来源：origin: prestosql/presto

queryRunner.installPlugin(new Plugin()

代码示例来源：origin: prestosql/presto

@Test
public void testCharTrailingSpace()
    throws Exception
{
  execute("CREATE TABLE tpch.char_trailing_space (x char(10))");
  assertUpdate("INSERT INTO char_trailing_space VALUES ('test')", 1);
  assertQuery("SELECT * FROM char_trailing_space WHERE x = char 'test'", "VALUES 'test'");
  assertQuery("SELECT * FROM char_trailing_space WHERE x = char 'test  '", "VALUES 'test'");
  assertQuery("SELECT * FROM char_trailing_space WHERE x = char 'test        '", "VALUES 'test'");
  assertEquals(getQueryRunner().execute("SELECT * FROM char_trailing_space WHERE x = char ' test'").getRowCount(), 0);
  Map<String, String> properties = ImmutableMap.of("deprecated.legacy-char-to-varchar-coercion", "true");
  Map<String, String> connectorProperties = ImmutableMap.of("connection-url", postgreSqlServer.getJdbcUrl());
  try (QueryRunner queryRunner = new DistributedQueryRunner(getSession(), 3, properties);) {
    queryRunner.installPlugin(new PostgreSqlPlugin());
    queryRunner.createCatalog("postgresql", "postgresql", connectorProperties);
    assertEquals(queryRunner.execute("SELECT * FROM char_trailing_space WHERE x = char 'test'").getRowCount(), 0);
    assertEquals(queryRunner.execute("SELECT * FROM char_trailing_space WHERE x = char 'test  '").getRowCount(), 0);
    assertEquals(queryRunner.execute("SELECT * FROM char_trailing_space WHERE x = char 'test       '").getRowCount(), 0);
    MaterializedResult result = queryRunner.execute("SELECT * FROM char_trailing_space WHERE x = char 'test      '");
    assertEquals(result.getRowCount(), 1);
    assertEquals(result.getMaterializedRows().get(0).getField(0), "test      ");
  }
  assertUpdate("DROP TABLE char_trailing_space");
}

代码示例来源：origin: prestosql/presto

@Test
public void testCharTrailingSpace()
    throws Exception
{
  execute("CREATE TABLE tpch.char_trailing_space (x char(10))");
  assertUpdate("INSERT INTO char_trailing_space VALUES ('test')", 1);
  assertQuery("SELECT * FROM char_trailing_space WHERE x = char 'test'", "VALUES 'test'");
  assertQuery("SELECT * FROM char_trailing_space WHERE x = char 'test  '", "VALUES 'test'");
  assertQuery("SELECT * FROM char_trailing_space WHERE x = char 'test        '", "VALUES 'test'");
  assertEquals(getQueryRunner().execute("SELECT * FROM char_trailing_space WHERE x = char ' test'").getRowCount(), 0);
  Map<String, String> properties = ImmutableMap.of("deprecated.legacy-char-to-varchar-coercion", "true");
  Map<String, String> connectorProperties = ImmutableMap.of("connection-url", mysqlServer.getJdbcUrl());
  try (QueryRunner queryRunner = new DistributedQueryRunner(getSession(), 3, properties);) {
    queryRunner.installPlugin(new MySqlPlugin());
    queryRunner.createCatalog("mysql", "mysql", connectorProperties);
    assertEquals(queryRunner.execute("SELECT * FROM char_trailing_space WHERE x = char 'test'").getRowCount(), 0);
    assertEquals(queryRunner.execute("SELECT * FROM char_trailing_space WHERE x = char 'test  '").getRowCount(), 0);
    assertEquals(queryRunner.execute("SELECT * FROM char_trailing_space WHERE x = char 'test       '").getRowCount(), 0);
    MaterializedResult result = queryRunner.execute("SELECT * FROM char_trailing_space WHERE x = char 'test      '");
    assertEquals(result.getRowCount(), 1);
    assertEquals(result.getMaterializedRows().get(0).getField(0), "test      ");
  }
  assertUpdate("DROP TABLE char_trailing_space");
}