DDL

表相关DDL

Create Table

该命令用来创建一张表，GeaFlow将其识别为外部表并将元数据存储在Catalog中。

Syntax

CREATE TABLE <table name> 
(
	<column name> <data type>
	[ { , <column name> <data type> } ... ]
) WITH （
	type = <table type>
	[ { , <config key> = <config value> } ... ]
);

Example

Create Table v_person_table (
	id bigint,
	name string,
	age int
) WITH (
	type='file',
	geaflow.dsl.file.path = 'resource:///data/persons.txt'
);

这个例子创建了一张表v_person_table，包含id, name, age三列，表的存储类型为文件，并通过geaflow.dsl.file.path参数说明需要访问的文件存放在引擎资源的指定目录中。

数据类型

类型	说明
BOOLEAN	布尔类型
SHORT	短整形类型，范围: -2^15 + 1 ~ 2^15-1
INT	整形类型， 范围: -2^31 + 1 ~ 2^31-1
LONG	长整形类型，范围: -2^63 + 1 ~ 2^63-1
DOUBLE	双精度浮点类型，范围: -2^1024 ~ +2^1024
VARCHAR	字符串类型
TIMESTAMP	时间戳类型

参数

创建表的同时，可以使用WITH指定表的参数信息，其中type参数用于指定外部表的存储类型，其他参数为kv类型。

Example

CREATE TABLE person (
	id   VARCHAR,
	name VARCHAR,
	age INT
) WITH (
	type ='file',
	geaflow.dsl.file.path = '/path/to/person/',
	geaflow.dsl.column.separator = '|',
	geaflow.dsl.window.size = 5000
);

这个例子创建一个文件类型的表，并指定表参数。其中type指定表类型为文件; geaflow.dsl.file.path文件路径;geaflow.dsl.column.separator指定字段分隔列; geaflow.dsl.window.size指定每批次读取文件的行数。

Create View

Syntax

CREATE VIEW <table veiw name> 
(
	<column name>
	[ { , <column name>} ... ]
) AS
	<table query>
;

Example

CREATE VIEW console_1 (a, b, c) AS
SELECT id, name, age FROM v_person_table;

图相关DDL

Create Graph

Syntax 一个图至少包含一对点边，点表必须包含一个id字段作为主键，边表必须包含srcId和targetId作为主键，边表还可以有一个时间戳字段标识时间。

CREATE GRAPH <graph name> 
(
	<graph vertex>
	[ { , <graph vertex> } ... ]
	, <graph edge>
	[ { , <graph edge> } ... ]
) WITH （
	storeType = <graph store type>
	[ { , <config key> = <config value> } ... ]
);

<graph vertex>  ::=
VERTEX <vertex name>
(
	<column name> <data type> ID
	[ {, <column name> <data type> } ... ]
)

<graph edge>  ::=
Edge <edge name>
(
	<column name> <data type> SOURCE ID
	, <column name> <data type> DESTINATION ID
	[ , <column name> <data type> TIMESTAMP ]
	[ {, <column name> <data type> } ... ]
)

Example

CREATE GRAPH dy_modern (
	Vertex person (
		id bigint ID,
		name varchar,
		age int
	),
	Vertex software (
		id bigint ID,
		name varchar,
		lang varchar
	),
	Edge knows (
		srcId bigint SOURCE ID,
		targetId bigint DESTINATION ID,
		weight double
	),
	Edge created (
		srcId bigint SOURCE ID,
		targetId bigint DESTINATION ID,
		weight double
	)
) WITH (
	storeType = 'rocksdb',
	shardCount = 2
);

这个例子创建了一张包含2个点2个边的图，存储类型为rocksdb, 分片数2个。

图存储

图的存储类型可以在WITH关联的配置列表中使用storeType配置项指定，目前GeaFlow支持Memory, RocksDB作为图存储格式。

图的存储分片数通过shardCount配置项指定，图的存储分片数影响图计算时的并发数，设为更大的值可以利用更多机器并发计算，但所需资源数也将增长。

自定义函数

Create Function

这个命令用来引入一个自定义函数。

Syntax

CREATE FUNCTION <function name> AS <implementation class>

Example

CREATE FUNCTION mysssp AS 'com.antgroup.geaflow.dsl.udf.graph.SingleSourceShortestPath';