I think I found the solution in EnumerableWindow's translateBound method. It works for most basic scenario I'm testing. I am hopeful that it will work for other scenarios as well.
Thanks Milinda On Wed, Oct 14, 2015 at 9:59 AM, Milinda Pathirage <[email protected]> wrote: > Hi Devs, > > I am trying to generate code for subtracting interval specified in a > sliding window clause from a timestamp (derived from the incoming tuple in > a streaming setting). But still not sure how to do this due to > incompatibility in types. Is there any standard way to do this? Highly > appreciate any tips regarding this. > > Thanks > Milinda > > -- > Milinda Pathirage > > PhD Student | Research Assistant > School of Informatics and Computing | Data to Insight Center > Indiana University > > twitter: milindalakmal > skype: milinda.pathirage > blog: http://milinda.pathirage.org > -- Milinda Pathirage PhD Student | Research Assistant School of Informatics and Computing | Data to Insight Center Indiana University twitter: milindalakmal skype: milinda.pathirage blog: http://milinda.pathirage.org
