MAPREDUCE服务 MRS-Spark从HBase读取数据再写入HBase样例程序（Python）:代码样例

时间：2024-06-29 14:10:56

MAPREDUCE服务 MRS Spark从HBase读取数据再写入HBase样例程序

代码样例

由于pyspark不提供Hbase相关api，本样例使用Python调用Java的方式实现。

下面代码片段仅为演示，具体代码参见SparkHbasetoHbasePythonExample：

# -*- coding:utf-8 -*-

from py4j.java_gateway import java_import
from pyspark.sql import SparkSession

# 创建SparkSession，设置kryo序列化
spark = SparkSession\
        .builder\
        .appName("SparkHbasetoHbase") \
        .config("spark.serializer", "org.apache.spark.serializer.KryoSerializer") \
        .config("spark.kryo.registrator", "com.huawei.bigdata.spark.examples.MyRegistrator") \
        .getOrCreate()

# 向sc._jvm中导入要运行的类
java_import(spark._jvm, 'com.huawei.bigdata.spark.examples.SparkHbasetoHbase')

# 创建类实例并调用方法
spark._jvm.SparkHbasetoHbase().hbasetohbase(spark._jsc)

# 停止SparkSession
spark.stop()

上一篇：MAPREDUCE服务 MRS-常见jar包冲突处理方式:问题现象

下一篇：MAPREDUCE服务 MRS-准备Flink安全认证:安全认证