Re: Behavior of TimestampCombiner?

2019-11-12 Thread Robert Bradshaw
, in Java, 9.999000), but the >>> results for LATEST and EARLIEST should be 9 and 0 respectively. >>> >>> On Mon, Nov 11, 2019 at 5:34 PM Ruoyun Huang wrote: >>> > >>> > Hi, Folks, >>> > >>> > I am trying to understa

Re: Behavior of TimestampCombiner?

2019-11-12 Thread Ruoyun Huang
; >> > Hi, Folks, >> > >> > I am trying to understand the behavior of TimestampCombiner. I have >> a test like this: >> > >> > class TimestampCombinerTest(unittest.TestCase): >> > >> > def test_combiner_latest(self): >> >

Re: Behavior of TimestampCombiner?

2019-11-12 Thread Ruoyun Huang
RLIEST should be 9 and 0 respectively. > > On Mon, Nov 11, 2019 at 5:34 PM Ruoyun Huang wrote: > > > > Hi, Folks, > > > > I am trying to understand the behavior of TimestampCombiner. I have > a test like this: > > > > class TimestampCombinerTest(uni

Re: Behavior of TimestampCombiner?

2019-11-11 Thread Robert Bradshaw
The END_OF_WINDOW is indeed 9.99 (or, in Java, 9.999000), but the results for LATEST and EARLIEST should be 9 and 0 respectively. On Mon, Nov 11, 2019 at 5:34 PM Ruoyun Huang wrote: > > Hi, Folks, > > I am trying to understand the behavior of TimestampCombiner. I have a

Behavior of TimestampCombiner?

2019-11-11 Thread Ruoyun Huang
Hi, Folks, I am trying to understand the behavior of TimestampCombiner. I have a test like this: 1. class TimestampCombinerTest(unittest.TestCase): 2. 3. def test_combiner_latest(self): 4. """Test TimestampCombiner with LATEST.""" 5. op