You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 洗你的头 <12...@qq.com> on 2020/10/31 13:15:16 UTC

pyflink的where该如何使用？如何筛选？

尊敬的开发者您好：我想要在输出表中进行条件筛选，使用了where语句，结果不行
我的代码如下：
#&nbsp;处理流程
t_env.from_path('mySource')&nbsp;\
&nbsp;&nbsp;&nbsp;&nbsp;.select("pickup_datetime,&nbsp;dropoff_datetime,&nbsp;pickup_longitude,&nbsp;pickup_latitude,&nbsp;dropoff_longitude,&nbsp;dropoff_latitude,&nbsp;distance_meters(pickup_longitude,&nbsp;pickup_latitude)&nbsp;as&nbsp;O,&nbsp;distance_meters(dropoff_longitude,&nbsp;dropoff_latitude)&nbsp;as&nbsp;D,&nbsp;compute_duration_time(pickup_datetime,&nbsp;dropoff_datetime)&nbsp;as&nbsp;duration")&nbsp;\
&nbsp;&nbsp;&nbsp;&nbsp;.where("duration&nbsp;&gt;=&nbsp;120&nbsp;&amp;&amp;&nbsp;duration&nbsp;<=&nbsp;3600")&nbsp;\
&nbsp;&nbsp;&nbsp;&nbsp;.select("pickup_datetime,&nbsp;dropoff_datetime,&nbsp;pickup_longitude,&nbsp;pickup_latitude,&nbsp;dropoff_longitude,&nbsp;dropoff_latitude,&nbsp;O,&nbsp;D,&nbsp;is_same_od(O,&nbsp;D)&nbsp;as&nbsp;same_od,&nbsp;duration")&nbsp;\
&nbsp;&nbsp;&nbsp;&nbsp;.where("same_od&nbsp;==&nbsp;0")&nbsp;\
&nbsp;&nbsp;&nbsp;&nbsp;.select("pickup_datetime,&nbsp;dropoff_datetime,&nbsp;pickup_longitude,&nbsp;pickup_latitude,&nbsp;dropoff_longitude,&nbsp;dropoff_latitude,&nbsp;O,&nbsp;D,&nbsp;duration")&nbsp;\
&nbsp;&nbsp;&nbsp;&nbsp;.insert_into('mySink')
请问我这样使用where为什么不行呢？我应该如何去筛选出想要的结果呢？
（尝试了去掉where是可以正常运行的）