AnalyticsCatalogContext

The analytics catalog context: one service, centrally managed, holds the warehouse's data sources and, built on them, the wide tables a dataset serves. Its source aggregate is one physical table or view of the warehouse, identified by (connection, database, table) (sourceIdOf): a table the Wow ClickHouse Sink keeps, described by its trusted wow_catalog row, or a table an analyst provides, drafted from system.columns and reviewed. Its dataset aggregate is a wide table over the sources (-2), identified by the name queries read it by (datasetIdOf).

Properties

Link copied to clipboard
const val NAME: String
Link copied to clipboard
const val TENANT_ID: String

The one tenant every source is in: the platform's (the aggregate type's fixed tenant).

Functions

Link copied to clipboard
fun datasetIdOf(context: String, name: String): String

The id of the dataset name of context: <context>.<name>, the name its queries read it by.

Link copied to clipboard
fun sourceIdOf(connection: String, database: String, table: String): String

The id of the source of database's table on the warehouse connection: <connection>:<database>:<table>.