spark_ open()

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

描述:

创建Spark数据库连接

语法:

spark_open()

创建本地连接

spark_open(hdfsUrl)

创建hdfs连接

spark_open(hdfsUrl,thriftUrl,dbname)

进行Spark数据库连接

备注:

外部库函数,进行Spark数据库连接。

参数:

hdfsUrl

Hdfs连接信息,格式为hdfs://ip:port,表示hdfsIP与端口号

thriftUrl

Thrift连接信息,格式为thrift://ip:port,表示thriftIP与端口号

dbname

数据库名称

返回值:

游标

示例:

 

A

 

1

=spark_open()

创建本地连接

2

=spark_open("hdfs://192.168.0.8:9000")

创建hdfs连接

3

=spark_open("hdfs://192.168.0.8:9000","thrift://192.168.0.8:9083","aa")

进行spark数据库连接

相关概念:

spark_close()

spark_cursor()

spark_query()