创建INTERVAL RANGE分区
由于partition expression只能是INT_RESULT，所以不需要显式指定type，设定大小即可*/CREATE TABLE t(a int,b datetime)PARTITION BY RANGE(MONTH(b))INTERVAL(1)(PARTITION p0 VALUES LESS THAN(2));由于分区键不是时间类型，设定间隔为...
Cava 运算符
加法：操作符两边的操作数相加 int a=left+right;a结果为30-减法：左边的操作数减去右边的操作数 int a=left-right;a结果为10*乘法：操作符两边的操作数相乘 int a=left*right;a结果为200/除法：左边的操作数除以右边的操作数 int a=left/...
Cava 运算符
加法：操作符两边的操作数相加 int a=left+right;a结果为30-减法：左边的操作数减去右边的操作数 int a=left-right;a结果为10*乘法：操作符两边的操作数相乘 int a=left*right;a结果为200/除法：左边的操作数除以右边的操作数 int a=left/...
Cava 异常处理
int a=1/b;除0异常-double c=0;double b=1/c;浮点数除0不抛异常 int a=1/c;浮点数除0不抛异常 最佳实践：int b=0;int a=0；if(b!0){ a=1/b;} 数组访问越界异常 代码示例：int[]a=new int[10];a[-1]/不合法，超数组下限 a[10]/不合法，超数...
Cava 异常处理
int a=1/b;除0异常-double c=0;double b=1/c;浮点数除0不抛异常 int a=1/c;浮点数除0不抛异常 最佳实践：int b=0;int a=0；if(b!0){ a=1/b;} 数组访问越界异常 代码示例：int[]a=new int[10];a[-1]/不合法，超数组下限 a[10]/不合法，超数...
Cava 分支结构
if 语句 语法结构：if(condition){/condition为布尔表达式/condition为true时，需要执行的代码 } 代码示例：class Example { static int main(){ int a=1;int b=2;if(a){ a=b;} return a;} } if…else…语句 语法结构：if(condition){/...
Cava 分支结构
if 语句 语法结构：if(condition){/condition为布尔表达式/condition为true时，需要执行的代码 } 代码示例：class Example { static int main(){ int a=1;int b=2;if(a){ a=b;} return a;} } if…else…语句 语法结构：if(condition){/...
合约数据类型
平台建议使用数据类型示例如下所示：数据类型 参考样例 合约内部是否支持 输入参数是否支持 bool bool a=true 是 是 uint uint a=1 是 是 uint8~uint256 uint8 a=1 是 是 int int a=1 是 是 int8~int256 int8 a=1 是 是 bytes bytes a=...
Cava 类型和变量定义
局部变量 数值类型变量 定义一个 int 类型的局部变量 a，并赋值为 10 class Example {/.int test(){ int a;a=10;return a+1;}/.} 直接使用初始值 10 定义局部变量 a class Example {/.int test(){ int a=10;a+1;}/.} 对象变量 ...
Cava 类型和变量定义
局部变量 数值类型变量 定义一个 int 类型的局部变量 a，并赋值为 10 class Example {/.int test(){ int a;a=10;return a+1;}/.} 直接使用初始值 10 定义局部变量 a class Example {/.int test(){ int a=10;a+1;}/.} 对象变量 ...
合约语言特性
整数运算 有符号整数溢出 int i=INT_MAX+1;非法位移运算 int i=1;int j=1;非法数学运算 int i=1/0;指针操作 访问空指针 int*p=nullptr;p=0;访问分配空间为 0 的指针 int*p=new int[0];p=0;访问已被释放的指针 int*p=new int;delete p;p=0;...
合约语言特性
整数运算 有符号整数溢出 int i=INT_MAX+1;非法位移运算 int i=1;int j=1;非法数学运算 int i=1/0;指针操作 访问空指针 int*p=nullptr;p=0;访问分配空间为 0 的指针 int*p=new int[0];p=0;访问已被释放的指针 int*p=new int;delete p;p=0;...
Cava 循环结构
简介 cava中通过循环结构来支持对同一个操作执行多次，目前cava仅支持for...示例代码：class Example { static int main(){ int a=0;for(int i=0;i;i){ if(i=1){ continue;} if(a>10){ break;} a+i;} int j=0;for;i;j){ a+j;} return a;} }
Cava 循环结构
简介 cava中通过循环结构来支持对同一个操作执行多次，目前cava仅支持for...示例代码：class Example { static int main(){ int a=0;for(int i=0;i;i){ if(i=1){ continue;} if(a>10){ break;} a+i;} int j=0;for;i;j){ a+j;} return a;} }
Math
static int max(int a,int b)返回两个int类型的值的最大值 static long max(long a,long b)返回两个long类型的值的最大值 static float max(float a,float b)返回两个float类型的值的最大值 static double max(double a,double b)返回两个...
Math
static int max(int a,int b)返回两个int类型的值的最大值 static long max(long a,long b)返回两个long类型的值的最大值 static float max(float a,float b)返回两个float类型的值的最大值 static double max(double a,double b)返回两个...
varbitx
bit_rand(int a,int b,float c)returns varbit 填充a长度的随机BIT，并指定b（0或1）的随机比例c。例如：bit_rand(10,1,0.3)可能返回0101000001。bit_posite(varbit a,int b,boolean c)returns int[]返回b（0或1）的下标位置数组，下标从0...
varbitx
bit_rand(int a,int b,float c)returns varbit 填充a长度的随机BIT，并指定b（0或1）的随机比例c。例如：bit_rand(10,1,0.3)可能返回0101000001。bit_posite(varbit a,int b,boolean c)returns int[]返回b（0或1）的下标位置数组，下标从0...
varbitx
bit_rand(int a,int b,float c)returns varbit 填充a长度的随机BIT，并指定b（0或1）的随机比例c。例如：bit_rand(10,1,0.3)可能返回0101000001。bit_posite(varbit a,int b,boolean c)returns int[]返回b（0或1）的下标位置数组，下标从0...
位图功能扩展（varbitx）
bit_rand(int a,int b,float c)returns varbit 填充a长度的随机BIT，并指定b（0或1）的随机比例c。例如：bit_rand(10,1,0.3)可能返回0101000001。bit_posite(varbit a,int b,boolean c)returns int[]返回b（0或1）的下标位置数组，下标从0...
uservice
} void demo_add(int a,int b){ struct cmd_param cmd;cmd.a=a;cmd.b=b;int c;微服务同步调用 CMD_1*/uservice_call_sync(demo.srv,CMD_1,&cmd,&c,sizeof(int));} 服务调用 int demo_subscribe(uint16_t event_id,event_callback_t cb,void...
变更Sink
CREATE TABLE MyTable(a int,b bigint,c varchar);CREATE TABLE MySink1(a int,b bigint,c varchar);CREATE TABLE MySink2(a int,b bigint,c varchar);INSERT INTO MySink1 SELECT a,sum(b),max(c)FROM MyTable GROUP BY a;INSERT INTO ...
使用介绍
price|brand|size|1|3599|Huawei|5.9|2|4388|Huawei|5.5|3|899|Xiaomi|5|notcontain 原型 boolean notcontain(INT a,const string b)boolean notcontain(LITERAL a,const string b)boolean notcontain(INT_ARRAY a,const string b)boolean ...
变更Source
create table MyTable(a int,b bigint,c varchar)with('connector'='datagen');select a,sum(b),max(c)from MyTable group by a;新增字段：d，该修改属于完全兼容变更。Query中未使用到字段d。create table MyTable(a int,b bigint,c ...
其他限制
create table MySink(a int,b bigint,c varchar)with('connector'='print');insert into MySink select a,sum(b),max(c)from MyTable group by a;修改Sink表：MySink->MySink2，和修改统计函数：max(c)->min(c)，该修改属于无法判断的修改...
Union All
create table MyTable2(a int,b bigint,c varchar,d int);原始SQL。select a,sum(b),max(c)from(select a,b,c from MyTable union all select a,b,c from MyTable2)group by a;调整Union All的输入Query的顺序，该修改属于完全兼容修改。...
分布键Distribution Key
设置a、b两列为distribution key，系统对a,b两个列的值做hash操作，再取模，即hash(a,b)%shard_count=shard_id，结果相同的一组数据分布在同一个Shard内 CREATE TABLE tbl(a int NOT NULL,b text NOT NULL)WITH(distribution_key='a,b');...
ALTER TABLE
示例 CREATE TABLE test_change(a int,b int,c int);First change column a’s name to a1.ALTER TABLE test_change CHANGE a a1 INT;Add a comment to column a1 ALTER TABLE test_change CHANGE a1 a1 INT COMMENT 'this is column a1';
创建边缘容器
i+{ s:=strconv.Itoa(pi[i])s=strings.Repeat("0",4-len(s))+s sb.WriteString(s)} return sb.String()} func computePi(n int)(i,N int,pi[]int){ N=n/4+3 pi=make([]int,N)var j,k,p,q,r,t,u,v int a,b:=[2]int{956,80},[2]int{57121,25}...
自定义函数迁移指南
FunctionHint(output=DataTypeHint("ROW,i INT>"))public static class OverloadedFunction extends TableFunction<Row>{ public void eval(int a,int b){ collect(Row.of("Sum",a+b));} public void eval(){ collect(Row.of("Empty args",...
重要参数说明
CREATE TEMPORARY TABLE s1(a INT,b INT,ts TIMESTAMP(3))WITH('connector'='datagen','rows-per-second'='1','fields.ts.kind'='random','fields.ts.max-past'='5s','fields.b.kind'='random','fields.b.min'='0','fields.b.max'='10');...
自定义审批系统对接接口
byte[]lengthByte=Utils.int2Bytes(plainTextBytes.length);ByteArrayOutputStream byteStream=new ByteArrayOutputStream();byteStream.write(randomBytes);byteStream.write(lengthByte);byteStream.write(plainTextBytes);byte[]...
全局二级索引（GSI）
CREATE TABLE t1(a INT PRIMARY KEY,b INT,INDEX k1(b)GLOBAL)PARTITION BY RANGE(`a`)(PARTITION p0 VALUES LESS THAN(5)ENGINE=InnoDB,PARTITION p1 VALUES LESS THAN(10)ENGINE=InnoDB);删除 t1 表上的 p1 分区并重建全局二级索引。...
创建表 CREATE TABLE 的不兼容点
示例如下：CREATE TABLE group_by_t1(a INT GENERATED ALWAYS AS(1)VIRTUAL,b INT GENERATED ALWAYS AS(a)VIRTUAL,c INT GENERATED ALWAYS AS(1)VIRTUAL);创建索引或约束 创建约束时，MySQL 数据库和 OceanBase 数据库 MySQL 租户对于列的...
表存储格式定义
CREATE TABLE foo(a int,b text)DISTRIBUTED BY(a);说明 当采用数据传输服务DTS写入 云原生数据仓库 AnalyticDB PostgreSQL 版 数据时，云原生数据仓库 AnalyticDB PostgreSQL 版 的目标表应设计为行存表，而不要采用列存表。DTS为准实时...
快速入门
} 调用示例：public interface TestRemoteRpcService {@PushRcpSetting(timeout=3000)void addInt(int a,int b,int c,PushRpcListener listener);void addString(String a,String b,PushRpcListener listener);} void callRemoteFunc(){ ...
创建GLOBAL INDEX
创建Global partition unique range index：CREATE TABLE partition_range(a int,b int,id integer,created_date timestamp without time zone)PARTITION BY RANGE(created_date);CREATE TABLE partition_range_part01(a int,b int,id ...
同构数据源访问
CREATE FOREIGN TABLE s01.t1(a int,b int)server<data_source_name>options(schema_name 's01',table_name 't1');data_source_name为数据源名称，可在控制台 同构数据源访问 页签查看。上述方式的优缺点如下：优点：可以灵活定制外表的DDL...
LIST DEFAULT HASH
一级分区存在多个LIST DEFAULT HASH分区的情况下，仅支持HASH或KEY二级分区：CREATE TABLE list_default_hash_sub(a INT,b INT)PARTITION BY LIST(a)SUBPARTITION BY HASH(b)SUBPARTITIONS 20(PARTITION p0 VALUES IN(1,2,3,4,5),PARTITION...
pldbgapi
CREATE OR REPLACE FUNCTION add_numbers(a int,b int)RETURNS NUMERIC AS$DECLARE t1_b_avg NUMERIC;BEGIN-DROP TABLE t1;CREATE TABLE t1(a int,b int,c int,d int);RAISE NOTICE 'Finish CREATE ';FOR i IN 1.10 LOOP INSERT INTO t1 ...
- 产品推荐
- 这些文档可能帮助您