~paul-lucas/zorba/bug-932374

« back to all changes in this revision

Viewing changes to src/runtime/core/gflwor/groupby_iterator.cpp

  • Committer: Paul J. Lucas
  • Date: 2012-09-21 20:26:47 UTC
  • mfrom: (10819.2.235 zorba)
  • Revision ID: paul@lucasmail.org-20120921202647-fy9n4jduhrnljrnb
MergeĀ fromĀ trunk.

Show diffs side-by-side

added added

removed removed

Lines of Context:
231
231
      
232
232
  theTupleIter->open(planState, aOffset);
233
233
 
234
 
  ulong numSpecs = (ulong)theGroupingSpecs.size();
 
234
  csize numSpecs = theGroupingSpecs.size();
235
235
 
236
 
  for (ulong i = 0; i < numSpecs; ++i)
 
236
  for (csize i = 0; i < numSpecs; ++i)
237
237
  {
238
238
    GroupingSpec& spec = theGroupingSpecs[i];
239
239
 
249
249
    }
250
250
  }
251
251
 
252
 
  numSpecs = (ulong)theNonGroupingSpecs.size();
 
252
  numSpecs = theNonGroupingSpecs.size();
253
253
 
254
 
  for (ulong i = 0; i < numSpecs; ++i)
 
254
  for (csize i = 0; i < numSpecs; ++i)
255
255
  {
256
256
    theNonGroupingSpecs[i].open(planState, aOffset);
257
257
  }
263
263
********************************************************************************/
264
264
void GroupByIterator::closeImpl(PlanState& planState) 
265
265
{
266
 
  ulong numSpecs = (ulong)theGroupingSpecs.size();
 
266
  csize numSpecs = theGroupingSpecs.size();
267
267
 
268
 
  for (ulong i = 0; i < numSpecs; ++i)
 
268
  for (csize i = 0; i < numSpecs; ++i)
269
269
  {
270
270
    theGroupingSpecs[i].close(planState);
271
271
  }
272
272
 
273
 
  numSpecs = (ulong)theNonGroupingSpecs.size();
 
273
  numSpecs = theNonGroupingSpecs.size();
274
274
 
275
 
  for (ulong i = 0; i < numSpecs; ++i)
 
275
  for (csize i = 0; i < numSpecs; ++i)
276
276
  {
277
277
    theNonGroupingSpecs[i].close(planState);
278
278
  }
288
288
********************************************************************************/
289
289
void GroupByIterator::resetImpl(PlanState& planState) const 
290
290
{
291
 
  ulong numSpecs = (ulong)theGroupingSpecs.size();
 
291
  csize numSpecs = theGroupingSpecs.size();
292
292
 
293
 
  for (ulong i = 0; i < numSpecs; ++i)
 
293
  for (csize i = 0; i < numSpecs; ++i)
294
294
  {
295
295
    theGroupingSpecs[i].reset(planState);
296
296
  }
297
297
 
298
 
  numSpecs = (ulong)theNonGroupingSpecs.size();
 
298
  numSpecs = theNonGroupingSpecs.size();
299
299
 
300
 
  for (ulong i = 0; i < numSpecs; ++i)
 
300
  for (csize i = 0; i < numSpecs; ++i)
301
301
  {
302
302
    theNonGroupingSpecs[i].reset(planState);
303
303
  }
332
332
  if (!lState->theGroupMap->empty()) 
333
333
  {
334
334
    lState->theGroupMapIter = lState->theGroupMap->begin();
 
335
 
335
336
    while(lState->theGroupMapIter != lState->theGroupMap->end())
336
337
    {
337
338
      bindGroupBy(lState->theGroupMapIter, lState, aPlanState);