Package-level declarations

Types

Link copied to clipboard
sealed interface BiDeploymentInspection
Link copied to clipboard
fun interface BiDeploymentInspector
Link copied to clipboard
data class BiScriptDiagnostic(val code: BiScriptDiagnosticCode, val aggregate: String, val path: String, val sourceType: String, val decision: BiScriptMappingDecision, val message: String)
Link copied to clipboard
class BiScriptGenerator(options: BiScriptOptions = BiScriptOptions())
Link copied to clipboard
sealed interface BiScriptOperation
Link copied to clipboard
data class BiScriptOptions(val database: String = "bi_db", val consumerDatabase: String = "bi_db_consumer", val topology: ClickHouseTopology = ClickHouseTopology.Cluster(), val timezone: String = "Asia/Shanghai", val kafkaBootstrapServers: String = DEFAULT_KAFKA_BOOTSTRAP_SERVERS, val topicPrefix: String = DEFAULT_TOPIC_PREFIX, val consumerGroupNamespace: String? = null, val kafkaOffsetStorage: KafkaOffsetStorage = KafkaOffsetStorage.BROKER, val kafkaKeeperPathPrefix: String = DEFAULT_KAFKA_KEEPER_PATH_PREFIX, val maxExpansionDepth: Int = 5, val unsupportedTypeStrategy: UnsupportedTypeStrategy = UnsupportedTypeStrategy.RAW_JSON, val omitSensitiveFields: Boolean = false)
Link copied to clipboard

Opaque immutable expansion plan for one BI script request.

Link copied to clipboard
data class BiScriptResult
Link copied to clipboard
class BiScriptService(inspector: BiDeploymentInspector = NoOpBiDeploymentInspector, scheduler: Scheduler = BI_SCRIPT_GENERATION_SCHEDULER)

Generates a BI script end to end: prepares the desired layout, inspects the ClickHouse catalog with inspector, and renders the script.

Link copied to clipboard

Reads Wow BI ownership markers directly from the ClickHouse system catalog.

Link copied to clipboard
data class ClickHouseClientOptions(val endpoints: List<URI>, val username: String = DEFAULT_USERNAME, val password: String = "", val connectionPoolEnabled: Boolean = true, val connectionTimeout: Duration = Duration.ofSeconds(3), val connectionRequestTimeout: Duration = Duration.ofSeconds(10), val socketTimeout: Duration = Duration.ofSeconds(10), val executionTimeout: Duration = Duration.ofSeconds(10), val maxConnections: Int = 10, val maxRetries: Int = 0)

Typed configuration for the ClickHouse Java client owned by ClickHouseBiDeploymentInspector.

Link copied to clipboard
sealed interface ClickHouseTopology