如何快速使用StarRocks

前提条件

已创建StarRocks集群，详情请参见创建StarRocks集群。

使用示例

使用SSH方式登录StarRocks集群，详情请参见登录集群。

执行以下命令，连接StarRocks集群。

mysql -h127.0.0.1 -P 9030 -uroot

执行以下命令，创建数据库并选择数据库。

CREATE DATABASE IF NOT EXISTS load_test; USE load_test;

执行以下命令，创建表。

CREATE TABLE insert_wiki_edit ( event_time DATETIME, channel VARCHAR(32) DEFAULT '', user VARCHAR(128) DEFAULT '', is_anonymous TINYINT DEFAULT '0', is_minor TINYINT DEFAULT '0', is_new TINYINT DEFAULT '0', is_robot TINYINT DEFAULT '0', is_unpatrolled TINYINT DEFAULT '0', delta INT SUM DEFAULT '0', added INT SUM DEFAULT '0', deleted INT SUM DEFAULT '0' ) AGGREGATE KEY(event_time, channel, user, is_anonymous, is_minor, is_new, is_robot, is_unpatrolled) PARTITION BY RANGE(event_time) ( PARTITION p06 VALUES LESS THAN ('2015-09-12 06:00:00'), PARTITION p12 VALUES LESS THAN ('2015-09-12 12:00:00'), PARTITION p18 VALUES LESS THAN ('2015-09-12 18:00:00'), PARTITION p24 VALUES LESS THAN ('2015-09-13 00:00:00') ) DISTRIBUTED BY HASH(user) BUCKETS 10 PROPERTIES("replication_num" = "1");

执行以下命令，导入测试数据。

INSERT INTO insert_wiki_edit VALUES("2015-09-12 00:00:00","#en.wikipedia","GELongstreet",0,0,0,0,0,36,36,0),("2015-09-12 00:00:00","#ca.wikipedia","PereBot",0,1,0,1,0,17,17,0);

执行以下命令，查询数据。

select * from insert_wiki_edit;

返回信息如下所示。

+---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+ | event_time | channel | user | is_anonymous | is_minor | is_new | is_robot | is_unpatrolled | delta | added | deleted | +---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+ | 2015-09-12 00:00:00 | #en.wikipedia | GELongstreet | 0 | 0 | 0 | 0 | 0 | 36 | 36 | 0 | | 2015-09-12 00:00:00 | #ca.wikipedia | PereBot | 0 | 1 | 0 | 1 | 0 | 17 | 17 | 0 | +---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+ 2 rows in set (0.16 sec)

使用Catalog管理内部和外部数据

EMR-5.8.0及后续版本的StarRocks集群支持使用Catalog（数据目录）管理内部和外部数据。StarRocks 2.3及以上版本提供以下两种数据目录：

Internal Catalog：内部数据目录，用于存储StarRocks内部所有的数据库和数据表。您可以使用内部数据目录管理内部数据。例如，执行CREATE DATABASE和CREATE TABLE语句创建的数据库和数据表都会存储在内部数据目录中。 每个StarRocks集群都有一个默认的内部数据目录default_catalog。StarRocks暂不支持修改默认的内部数据目录的名称，也不支持创建新的内部数据目录。

External Catalog：外部数据目录，用于管理外部数据源中的数据。创建外部数据目录时需指定外部数据源访问信息。创建后，无需创建外部表即可查询外部数据。

Catalog更多信息，请参见Catalog概述。

网址：如何快速使用StarRocks https://m.mxgxt.com/news/view/1263067

相关内容

如何利用 StarRocks 加速 Iceberg 数据湖的查询效率
快速上手StarRocks
如何使用Flink,通过CTAS语句同步MySQL数据至StarRocks
各位大佬， StarRocks 如果写入数据速度过快， 容易将 StarRocks 写挂。 有对这个
买好emr以后，dms可以连接使用starrocks吗
实时计算 Flink版产品使用问题之如何对starrocks进行分桶
使用SQL Editor连接StarRocks实例
使用docker部署单机测试版starrocks
StarRocks x Paimon 构建极速实时湖仓分析架构实践
如何配置StarRocks输出组件用于向数据源写入数据

随便看看