source: class TestOver {
  
      @Test
      public void testCountCurrentToUnboundedFollowing() throws Exception {
  
target:         Over func = new Over();
          DataBag inbag = BagFactory.getInstance().newDefaultBag();
          for (int i = 0; i < 10; i++) {
              Tuple t = TupleFactory.getInstance().newTuple(1);
              t.set(0, 1);
              inbag.add(t);
          }
          Tuple t = TupleFactory.getInstance().newTuple(4);
          t.set(0, inbag);
          t.set(1, "count");
          t.set(2, 0);
          t.set(3, -1);
          DataBag outbag = func.exec(t);
          assertEquals(10, outbag.size());
          int cnt = 10;
          for (Tuple to : outbag) {
              assertEquals(1, to.size());
              assertEquals(new Long(cnt--), to.get(0));
          }
      }
  
  }