vinlee19 opened a new pull request, #27269:
URL: https://github.com/apache/doris/pull/27269
we can use Apache Druid catalog as follows:
```sql
"type"="jdbc",
"jdbc_url" =
"jdbc:avatica:remote:url=http://ip:coordinator_port/druid/v2/sql/avatica/";,
"user" = "admin",
"password" = "password1",
"driver_url" = "avatica-1.23.0.jar",
"driver_class" = "org.apache.calcite.avatica.remote.Driver"
);
```
```sql
"type"="jdbc",
"jdbc_url" =
"jdbc:avatica:remote:url=http://ip:broker_port/druid/v2/sql/avatica/";,
"user" = "admin",
"password" = "password1",
"driver_url" = "avatica-1.23.0.jar",
"driver_class" = "org.apache.calcite.avatica.remote.Driver"
);
```
APACHE DRUID TYPE | Doris Type |
-- | -- | --
BIGINT | BIGINT |
FLOAT | DOUBLE |
DOUBLE | DOUBLE | 扩大一个数
TIMESTAMP | DATETIME |
VARCHAR | STRING |
COMPLEX<JSON> | JSON |
catalog:
```sql
CREATE CATALOG `jdbc_druid_auth` PROPERTIES (
"type" = "jdbc",
"jdbc_url" =
"jdbc:avatica:remote:url=http://localhost:8888/druid/v2/sql/avatica/";,
"driver_url" = "avatica-1.23.0.jar",
"user"="admin",
"password" = "password1",
"driver_class" = "org.apache.calcite.avatica.remote.Driver"
);
```
doris table:
```sql
CREATE TABLE `kttm1_doris` (
`__time` datetimev2(6) NOT NULL,
`agent_category` varchar(*) NULL,
`agent_type` varchar(*) NULL,
`browser` varchar(*) NULL,
`browser_version` varchar(*) NULL,
`city` varchar(*) NULL,
`continent` varchar(*) NULL,
`country` varchar(*) NULL,
`version` varchar(*) NULL,
`event_type` varchar(*) NULL,
`event_subtype` varchar(*) NULL,
`loaded_image` varchar(*) NULL,
`adblock_list` varchar(*) NULL,
`forwarded_for` varchar(*) NULL,
`language` varchar(*) NULL,
`number` varchar(*) NULL,
`os` varchar(*) NULL,
`path` varchar(*) NULL,
`platform` varchar(*) NULL,
`referrer` varchar(*) NULL,
`referrer_host` varchar(*) NULL,
`region` varchar(*) NULL,
`remote_address` varchar(*) NULL,
`screen` varchar(*) NULL,
`session` varchar(*) NULL,
`session_length` bigint(20) NOT NULL,
`timezone` varchar(*) NULL,
`timezone_offset` varchar(*) NULL,
`window` varchar(*) NULL
)DUPLICATE KEY(`__time`)
DISTRIBUTED BY HASH(`agent_category`) BUCKETS 10
PROPERTIES (
"replication_allocation" = "tag.location.default: 1"
);
```
case 1:
```sql
mysql> select count(*) from kttm1_doris;
+----------+
| count(*) |
+----------+
| 465346 |
+----------+
1 row in set (0.12 sec)
mysql> select count(*) from jdbc_druid_auth.druid.kttm1;
+----------+
| count(*) |
+----------+
| 465346 |
+----------+
1 row in set (0.72 sec)
```
case 2:
```sql
mysql> CREATE TABLE `wikipedia` (
-> `__time` datetimev2(6) NOT NULL,
-> `isRobot` varchar(*) NULL,
-> `channel` varchar(*) NULL,
-> `flags` varchar(*) NULL,
-> `isUnpatrolled` varchar(*) NULL,
-> `page` varchar(*) NULL,
-> `diffUrl` varchar(*) NULL,
-> `added` bigint(20) NOT NULL,
-> `comment` varchar(*) NULL,
-> `commentLength` bigint(20) NOT NULL,
-> `isNew` varchar(*) NULL,
-> `isMinor` varchar(*) NULL,
-> `delta` bigint(20) NOT NULL,
-> `isAnonymous` varchar(*) NULL,
-> `user` varchar(*) NULL,
-> `deltaBucket` bigint(20) NOT NULL,
-> `deleted` bigint(20) NOT NULL,
-> `namespace` varchar(*) NULL,
-> `cityName` varchar(*) NULL,
-> `countryName` varchar(*) NULL,
-> `regionIsoCode` varchar(*) NULL,
-> `metroCode` bigint(20) NOT NULL,
-> `countryIsoCode` varchar(*) NULL,
-> `regionName` varchar(*) NULL
-> )DUPLICATE KEY(`__time`)
-> DISTRIBUTED BY HASH(`__time`) BUCKETS 10
-> PROPERTIES (
-> "replication_allocation" = "tag.location.default: 1"
-> );
Query OK, 0 rows affected (0.04 sec)
mysql> insert into wikipedia select * from jdbc_druid_auth.druid.wikipedia;
Query OK, 24433 rows affected (0.95 sec)
{'label':'label_35fd9215e010495d_8a9292f5b3251936', 'status':'VISIBLE',
'txnId':'2004'}
mysql> select count(*) from wikipedia;
+----------+
| count(*) |
+----------+
| 24433 |
+----------+
1 row in set (0.05 sec)
mysql> select count(*) from jdbc_druid_auth.druid.wikipedia;
+----------+
| count(*) |
+----------+
| 24433 |
+----------+
1 row in set (0.18 sec)
```
Issue Number: close #xxx
<!--Describe your changes.-->
## Further comments
If this is a relatively large or complex change, kick off the discussion at
[d...@doris.apache.org](mailto:d...@doris.apache.org) by explaining why you
chose the solution you did and what alternatives you considered, etc...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
