描述:
创建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) |
|