数据管理

约束与限制

数据管理仅支持创建表和删除表。
单次请求只能执行单条SQL。
自定义Connector的表类型，不支持通过数据管理模块创建对应表。
本章节适用于MRS 3.6.0-LTS.1及以后版本。

操作步骤

访问Flink WebUI，请参考访问FlinkServer WebUI界面。

单击“数据管理”，下拉框选择创建好的Catalog，具体操作请参考Catalog管理，会自动带出Catalog包含的库和表。

构造建表语句:

在hive_catalog、default数据库中创建名称为“hive_table”的hive表，完整示例如下：

create table if not exists hive_catalog.`default`.hive_table (
  user_id STRING,
  item_id STRING,
  cat_id STRING,
  ts timestamp(9),
  dy STRING,
  ho STRING,
  mi STRING
) PARTITIONED BY (dy, ho, mi)
with
  (
    'connector' = 'hive',
    'partition.time-extractor.timestamp-pattern' = '$dy $ho:$mi:00',
    'sink.partition-commit.trigger' = 'process-time',
    'sink.partition-commit.delay' = '0S',
    'sink.partition-commit.policy.kind' = 'metastore,success-file'
  );

在hudi_catalog、default数据库中创建名称为“hudi_table”的hudi表，完整示例如下：

create table if not exists hudi_catalog.`default`.hudi_table (
  uuid VARCHAR(20),
  name VARCHAR(10),
  age INT,
  ts INT,
  `p` VARCHAR(20)
) PARTITIONED BY (`p`)
WITH
  (
    'connector' = 'hudi',
    'path' = 'hdfs://hacluster/tmp/hudi/hudi_table',
    'table.type' = 'MERGE_ON_READ',
    'hoodie.datasource.write.recordkey.field' = 'uuid',
    'index.type' = 'BUCKET',
    'hoodie.bucket.index.num.buckets' = '4',
    'write.precombine.field' = 'ts',
    'write.tasks' = '4'
  );

在iceberg_catalog、default数据库中创建名称为“iceberg_table”的iceberg表，完整示例如下：

CREATE TABLE if not exists iceberg_catalog.`default`.iceberg_table (
  id BIGINT COMMENT 'unique id',
  data STRING NOT NULL
) PARTITIONED BY (data)
WITH
  ('format-version' = '2');

在paimon_catalog、default数据库中创建名称为“paimon_table”的paimon表，完整示例如下：

CREATE TABLE if not exists paimon_catalog.`default`.paimon_table (
  user_id BIGINT,
  item_id BIGINT,
  behavior STRING,
  dt STRING,
  hh STRING,
  PRIMARY KEY (dt, hh, user_id) NOT ENFORCED
);