PyODPS学习:使用DataFrame实现SQL的IF判断

简介: 使用DataFrame实现SQL的IF判断

在编写SQL代码时,可能会遇到这种场景(假如有两个字段column1,column2,当字段1小于某个值时,字段2等于0).
1.sql语句可以使用CASE WHEN:

SELECT
    column1,
    (CASE WHEN column1<10 THEN 0 ELSE column2 END) AS column2
FROM tabelName;

2.使用IF语句

SELECT
    column1,
     IF(column1<10,0,column2) AS column2
FROM tabelName;

那这种情况在PyODPS的DataFrame对象怎么操作呢?

from odps.df import DataFrame

#运行时显示详细信息
from odps import options
options.verbose = True

OdpsTable=odps.get_table('**一个表**')
InitialData = DataFrame(OdpsTable)
InitialData[InitialData['column1']<10,'column2']=0

其实ODPS是执行了IF语句,并返回了一个新表重新赋值给了InitialData。可以将options.verbose = True,查看PyODPS与ODPS交互过程中运行的命令。
更多技巧参考文档:http://pyodps.readthedocs.io/zh_CN/latest/df-basic-zh.html

目录
相关文章
|
18天前
|
SQL JSON 分布式计算
【赵渝强老师】Spark SQL的数据模型:DataFrame
本文介绍了在Spark SQL中创建DataFrame的三种方法。首先,通过定义case class来创建表结构,然后将CSV文件读入RDD并关联Schema生成DataFrame。其次,使用StructType定义表结构,同样将CSV文件读入RDD并转换为Row对象后创建DataFrame。最后,直接加载带有格式的数据文件(如JSON),通过读取文件内容直接创建DataFrame。每种方法都包含详细的代码示例和解释。
|
2月前
|
SQL 存储 数据库
SQL学习一:ACID四个特性,CURD基本操作,常用关键字,常用聚合函数,五个约束,综合题
这篇文章是关于SQL基础知识的全面介绍,包括ACID特性、CURD操作、常用关键字、聚合函数、约束以及索引的创建和使用,并通过综合题目来巩固学习。
36 1
|
2月前
|
SQL 分布式计算 大数据
大数据-94 Spark 集群 SQL DataFrame & DataSet & RDD 创建与相互转换 SparkSQL
大数据-94 Spark 集群 SQL DataFrame & DataSet & RDD 创建与相互转换 SparkSQL
58 0
|
4月前
|
SQL 存储 关系型数据库
PostgreSQL核心之SQL基础学习
PostgreSQL核心之SQL基础学习
49 3
|
4月前
|
SQL 存储 分布式计算
|
6月前
|
SQL 存储 Java
SQL数据库学习指南:从基础到高级
SQL数据库学习指南:从基础到高级
|
5月前
|
SQL 存储 关系型数据库
关系型数据库SQL Server学习
【7月更文挑战第4天】
82 2
|
5月前
|
SQL 关系型数据库 MySQL
sql 学习
sql 学习
|
5月前
|
SQL 存储 Java
SQL数据库学习指南:从基础到高级
SQL数据库学习指南:从基础到高级
|
5月前
|
SQL 存储 Oracle
SQL中使用IF语句实现条件判断
SQL中使用IF语句实现条件判断