Package org.teiid.common.buffer

Examples of org.teiid.common.buffer.TupleBuffer.addTuple()

64
65
66
67
68
69
70
71
72
73
74
    tb.addTuple(Arrays.asList(5));
    tb.addTuple(Arrays.asList(6));
    tb.addTuple(Arrays.asList(7));
    tb.addTuple(Arrays.asList(8));
    tb.addTuple(Arrays.asList(9));
    tb.addTuple(Arrays.asList(10));
   
    tb.close();
   
    BufferManager bm = fbs.getBufferManager();
    CachedResults results = new CachedResults();
View Full Code Here
427
428
429
430
431
432
433
434
435
436
437
        return new CollectionTupleSource(Arrays.asList(Collections.nCopies(projectedCols.size(), count)).iterator());
      } else if (updatable) {
        tb = bm.createTupleBuffer(projectedCols, sessionID, TupleSourceType.PROCESSOR);
        List<?> next = null;
        while ((next = ts.nextTuple()) != null) {
          tb.addTuple(next);
        }
      } else {
        usingQueryTupleSource = true;
        return ts;
      }
View Full Code Here
252
253
254
255
256
257
258
259
260
261
262
            if (this.mode == Mode.SORT) {
              //perform a stable sort
            Collections.sort((List<List<?>>)workingTuples, comparator);
            }
            for (List<?> list : workingTuples) {
          sublist.addTuple(list);
        }
            workingTuples = null;
             
            sublist.saveBatch();
            } finally {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.