This repository was archived by the owner on Nov 7, 2025. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -85,13 +85,15 @@ func main() {
8585 }()
8686
8787 var connectionPool = clickhouse .InitDBConnectionPool (& cfg )
88+ //var connectionPool = doris.InitDBConnectionPool(&cfg)
8889
8990 phoneHomeAgent := telemetry .NewPhoneHomeAgent (& cfg , connectionPool , licenseMod .License .ClientID )
9091 phoneHomeAgent .Start ()
9192
9293 virtualTableStorage := persistence .NewElasticJSONDatabase (cfg .Elasticsearch , common_table .VirtualTableElasticIndexName )
9394 tableDisco := database_common .NewTableDiscovery (& cfg , connectionPool , virtualTableStorage )
9495 schemaRegistry := schema .NewSchemaRegistry (database_common.TableDiscoveryTableProviderAdapter {TableDiscovery : tableDisco }, & cfg , clickhouse .NewClickhouseSchemaTypeAdapter (cfg .DefaultStringColumnType ))
96+ //schemaRegistry := schema.NewSchemaRegistry(database_common.TableDiscoveryTableProviderAdapter{TableDiscovery: tableDisco}, &cfg, doris.NewDorisSchemaTypeAdapter(cfg.DefaultStringColumnType))
9597 schemaRegistry .Start ()
9698
9799 im := elasticsearch .NewIndexManagement (cfg .Elasticsearch )
You can’t perform that action at this time.
0 commit comments