Hi Team,
I want to Serialize the ResolvedExpression to String or byte[] and transmit it into LookupFunction, and parse it back to ResolvedExpression in the LookupFunction.
For my case:
Select * from left_stream as s join dim_table for system_time as of s.proc_time as d on s.id=d.id where d.pt > cast(from_unixtime(unix_timestamp()-3*60*60,'yyyy-MM-dd-HH') as string)
The filter will be pushed down to lookupFunction, and I hope that when a task is failover, the time to be filtered is calculated based on the failover time, not the time when the task is first started.
For example:
9.1 10:00:00 launch the task; // the lookupFunction will load the data after 9.1 7:00:00
9.5 10:00:00 the task failover; // hope loading the data after 9.5 7:00:00
Is there an approach to make ResolvedExpression serializable?
Best regards,
Xianxun
