wow-bi/me.ahoo.wow.bi

Package-level declarations

Types

value class BiConsumerIdentity(val value: String)

data class BiDeploymentDescriptor(val deploymentId: String, val configurationFingerprint: String, val topologyFingerprint: String)

BiDeploymentInspection

sealed interface BiDeploymentInspection

BiDeploymentInspectionException

sealed class BiDeploymentInspectionException : RuntimeException, ErrorInfoCapable

BiDeploymentInspector

fun interface BiDeploymentInspector

BiDeploymentPhase

enum BiDeploymentPhase : Enum<BiDeploymentPhase>

BiObjectKey

data class BiObjectKey(val database: String, val name: String)

BiObjectKind

enum BiObjectKind : Enum<BiObjectKind>

BiObjectMetadata

data class BiObjectMetadata(val protocolVersion: Int = CURRENT_PROTOCOL_VERSION, val layoutVersion: Int = CURRENT_LAYOUT_VERSION, val phase: BiDeploymentPhase = BiDeploymentPhase.STABLE, val deploymentId: String, val configurationFingerprint: String, val topologyFingerprint: String, val aggregate: String? = null, val kind: BiObjectKind, val consumerIdentity: String? = null, val registryRevision: Long? = null)

BiObjectMetadataCodec

object BiObjectMetadataCodec

BiScriptDiagnostic

data class BiScriptDiagnostic(val code: BiScriptDiagnosticCode, val aggregate: String, val path: String, val sourceType: String, val decision: BiScriptMappingDecision, val message: String)

BiScriptDiagnosticCode

enum BiScriptDiagnosticCode : Enum<BiScriptDiagnosticCode>

BiScriptGenerator

class BiScriptGenerator(options: BiScriptOptions = BiScriptOptions())

BiScriptMappingDecision

enum BiScriptMappingDecision : Enum<BiScriptMappingDecision>

BiScriptOperation

sealed interface BiScriptOperation

BiScriptOptions

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)

BiScriptPreparation

class BiScriptPreparation

Opaque immutable expansion plan for one BI script request.

BiScriptResult

data class BiScriptResult

ClickHouseBiDeploymentInspector

class ClickHouseBiDeploymentInspector : BiDeploymentInspector, AutoCloseable

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

ClickHouseClientOptions

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.

ClickHouseTopology

sealed interface ClickHouseTopology

KafkaOffsetStorage

enum KafkaOffsetStorage : Enum<KafkaOffsetStorage>

NoOpBiDeploymentInspector

data object NoOpBiDeploymentInspector : BiDeploymentInspector

ObservedBiDeployment

data class ObservedBiDeployment(val objects: List<ObservedBiObject>)

ObservedBiObject

data class ObservedBiObject(val database: String, val name: String, val engine: String, val engineFull: String = "", val createTableQuery: String = "", val metadata: BiObjectMetadata? = null)

UnsupportedTypeStrategy

enum UnsupportedTypeStrategy : Enum<UnsupportedTypeStrategy>