检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
CREATE TABLE hot_cold_table ( `f1` String, `f2` String, `f3` Int64, `f4` Float64, `date` Date ) ENGINE = MergeTree() PARTITION BY date ORDER
样例代码 private void createDatabase(String databaseName, String clusterName) throws Exception { String createDbSql = "create database
其中数据类型为创建的表所指定的三个字段,分别是String、UInt8和Date类型。 样例代码 String insertSql = "insert into " + databaseName + "." + tableName + " values (?,?,?)"
`order_channel` string, `order_time` string, `pay_amount` double, `real_pay` double, `pay_time` string, `user_id` string, `user_name` string
表7 Datastore 参数 是否必选 参数类型 描述 version 是 String controller版本号,默认1.0.6。 type 是 String 集群数据库类型。
order_channel string, order_time string, pay_amount double, real_pay double, pay_time string, user_id string, user_name string, area_id string
样例代码 private void createTable(String databaseName, String tableName, String clusterName) throws Exception { String createSql = "create table
create table DB.table1 ON CLUSTER default_cluster (id Int16,name String) ENGINE = MergeTree() ORDER BY (id); 创建视图。
响应参数 状态码: 400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误信息。 请求示例 扩容两个rs节点示例。
响应参数 状态码: 400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误信息。 请求示例 node_num范围是[2,10]。
create table DB.table1 ON CLUSTER default_cluster (id Int16,name String) ENGINE = MergeTree() ORDER BY (id); 插入数据。
Map<String, String>> fams = entry.getColumns(); for (Map.Entry<String, Map<String, String>> familyEntry : fams.entrySet()) {
样例代码 private void dropTable(String databaseName, String tableName, String clusterName) throws Exception { String dropLocalTableSql = "drop
cluster_name String CloudTable集群名称。 created String 集群创建时间。 enable_dfv String 是否开启DFV。 false:不开启 true:开启 enable_free String 集群是否免费。
updated String 集群更新时间。 created String 集群创建时间。 cluster_id String 集群唯一标识,集群ID。 status String 集群当前状态: 200:集群正常。 300:集群异常。 400:集群已删除。
String family = familyEntry.getKey(); Map<String, String> qualifiers = familyEntry.getValue(); for (Map.Entry<String, String
样例代码 private void queryData(String databaseName, String tableName) throws Exception { String querySql1 = "select * from " + databaseName
表4 HbaseModifySettingV2 参数 是否必选 参数类型 描述 id 否 String 参数ID。 parm_name 是 String 待修改的参数名。 new_value 是 String 设置的参数值。
表4 ParameterInfo 参数 参数类型 描述 id String 参数ID。 name String 配置名称。 default_value String 默认值。 value_type String 配置值类型。
Map<String, String>> fams = entry.getColumns(); for (Map.Entry<String, Map<String, String>> familyEntry : fams.entrySet()) {