Spark 读取clickhouse

第一步加入jar

<dependency>
        <groupId>ru.yandex.clickhouse</groupId>
        <artifactId>clickhouse-jdbc</artifactId>
        <version>0.2.6</version>
    </dependency>

第二步

public long prepareProductInfo(SparkSession s) {
     Dataset<Row> house=s.read().format("jdbc")
            .option("driver", "ru.yandex.clickhouse.ClickHouseDriver")
            .option("url", "jdbc:clickhouse://****:8123/ads_zz")
            .option("dbtable", "(select id, name, brand_id from *.* ) as tt")
            .option("user", "*")
            .option("password", "*")
            .load();   
     house.createOrReplaceTempView("product");   
     house.show(10, false); 
     return house.count();
  }

速度很快，性能还行！