analytics-catalog-server/me.ahoo.wow.analytics.catalog.server/ClickHouseWarehouseCatalog

ClickHouseWarehouseCatalog

class ClickHouseWarehouseCatalog(client: Client, val connection: String, val databases: List<String>) : WarehouseCatalog

The WarehouseCatalog of a ClickHouse server, over the host's client-v2 client:

the sources are the tables and views of databases that system.tables lists, but for the materialized views (their data is in the tables they write TO), their inner tables and wow_catalog itself;
a table's columns are system.columns', in order;
the wow_catalog rows of a table are those of format 1 in its database's wow_catalog, read with FINAL: a row of the same content written again is one row. A database without wow_catalog has none.

Each statement's result is read as JSONEachRow on Dispatchers.IO.

Constructors

ClickHouseWarehouseCatalog

constructor(client: Client, connection: String, databases: List<String>)

Properties

open override val connection: String

open override val databases: List<String>

open override val engine: String

Functions

open suspend override fun catalogChanges(database: String): Map<String, String>

open suspend override fun catalogRows(database: String, table: String): List<CatalogRow>

open suspend override fun table(database: String, table: String): WarehouseTable?

open suspend override fun tables(database: String): List<WarehouseTableInfo>

open override fun toString(): String