spark_ open()

阅读(1893) 标签: 创建, spark数据库,

描述:

创建Spark数据库连接。

语法:

spark_open([config])

备注:

外部库函数,外部库的使用请参考《外部库使用指南》。

通过加载配置文件,进行Spark数据库连接,返回数据库连接串。

参数:

config

.properties配置文件,放置在scu-spark-cli-xxx.jar中,具体请参考《外部库使用指南》,缺省表示本地连接。

选项:

@i

参数config存在时,读取Iceberg格式的数据,缺省读取Hudi格式。

返回值:

游标

示例:

 

A

 

1

=spark_open()

进行本地连接。

2

>spark_close(A1)

 

3

=spark_open("spark.properties")

连接Spark数据库。

4

>spark_close(A3)

 

5

=spark_open("hudi.properties")

连接Hudi格式的Spark数据库。

6

>spark_close(A5)

 

7

=spark_open@i("iceberg.properties")

连接Iceberg格式的Spark数据库。

8

>spark_close(A7)

 

9

=spark_open("hudi-s3.properties")

连接与S3关联的Hudi格式的Spark数据库。

10

>spark_close(A9)

 

11

=spark_open@i("iceberg-s3.properties")

连接与S3关联的Iceberg格式的Spark数据库。

12

>spark_close(A11)