pyflink??where??????????????????????

[????????]

??????????????????????????????????????????????????????where??????????????
??????????????
# ????????
t_env.from_path('mySource') \
    .select("pickup_datetime, dropoff_datetime, pickup_longitude, pickup_latitude, dropoff_longitude, dropoff_latitude, distance_meters(pickup_longitude, pickup_latitude) as O, distance_meters(dropoff_longitude, dropoff_latitude) as D, compute_duration_time(pickup_datetime, dropoff_datetime) as duration") \
&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??????????????????