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; .where("duration &gt;= 120 &amp;&amp; duration <= 3600") \
&nbsp; &nbsp; .select("pickup_datetime, dropoff_datetime, pickup_longitude, 
pickup_latitude, dropoff_longitude, dropoff_latitude, O, D, is_same_od(O, D) as 
same_od, duration") \
&nbsp; &nbsp; .where("same_od == 0") \
&nbsp; &nbsp; .select("pickup_datetime, dropoff_datetime, pickup_longitude, 
pickup_latitude, dropoff_longitude, dropoff_latitude, O, D, duration") \
&nbsp; &nbsp; .insert_into('mySink')
??????????????where??????????????????????????????????????????????
????????????where??????????????????