开发者社区 > 大数据与机器学习 > 人工智能平台PAI > 正文

需要根据分类的字段组合成新的表名,然后创建表。有人知道在机器学习PAI怎么实现吗?

如图,我之前是读取流式数据,直接导出到mysql一张表中。现在多了一个需求,需要先对流式数据进行分类,导出到mysql不同的表中。可能有的表还不存在,需要根据分类的字段组合成新的表名,然后创建表。有人知道在机器学习PAI怎么实现吗?
16c2133d4161db21bc3a18804a56037d.png

展开
收起
乐天香橙派 2023-08-27 15:12:10 62 0
1 条回答
写回答
取消 提交回答
  • 在 PAI 中创建表,可以使用 df.createOrReplaceTempView() 方法。如果需要根据分类的字段组合成新的表名,可以使用 df.withColumnRenamed() 方法来更改表名。例如,如果有一个 DataFrame df,里面有两个字段 category 和 data,我们可以根据分类字段 category 组合成新的表名,然后创建表

    df = spark.read.csv("data.csv")
    df = df.withColumnRenamed("category", "new_category")
    df.createOrReplaceTempView("my_table")
    
    2023-09-18 15:47:23
    赞同 展开评论 打赏

人工智能平台 PAI(Platform for AI,原机器学习平台PAI)是面向开发者和企业的机器学习/深度学习工程平台,提供包含数据标注、模型构建、模型训练、模型部署、推理优化在内的AI开发全链路服务,内置140+种优化算法,具备丰富的行业场景插件,为用户提供低门槛、高性能的云原生AI工程化能力。

相关产品

  • 人工智能平台 PAI
  • 相关电子书

    更多
    大规模机器学习在蚂蚁+阿里的应用 立即下载
    阿里巴巴机器学习平台AI 立即下载
    微博机器学习平台架构和实践 立即下载