spark_client()

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

描述:

创建Spark数据库连接

语法:

spark_client(hdfsUrl,thriftUrl,dbname)

备注:

外部库函数,进行Spark数据库连接,hdfsUrl格式为hdfs://ip:port,表示hdfsIP与端口号。thriftUrl格式为thrift://ip:port,表示thriftIP与端口号,dbname是数据库名称。

参数:

hdfsUrl

Hdfs连接信息

thriftUrl

Thrift连接信息

dbname

数据库名称

返回值:

数据库连接

示例:

 

A

 

1

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

连接Spark数据库

相关概念:

spark_close()

spark_cursor()

spark_query()