Package com.foundationdb.qp.row

Examples of com.foundationdb.qp.row.Row.rowType()

384
385
386
387
388
389
390
391
392
393
394
                    row = inputRow;
                    inputRow = null;
                } else {
                    do {
                        row = cursor.next();
                    } while ((row != null) && !outputRowTypes.contains(row.rowType()));
                    if (row == null) {
                        if (keepInput && !inputPrecedesBranch) {
                            assert inputRow != null;
                            row = inputRow;
                            inputRow = null;
View Full Code Here
450
451
452
453
454
455
456
457
458
459
460
        @Override
        public void open() {
            super.open();
            Row rowFromBindings = bindings.getRow(inputBindingPosition);
            assert rowFromBindings.rowType() == inputRowType : rowFromBindings;
            if (inputRowType != sourceRowType) {
                rowFromBindings = rowFromBindings.subRow(sourceRowType);
            }
            computeLookupRowHKey(rowFromBindings);
            cursor.rebind(hKey, true);
View Full Code Here
469
470
471
472
473
474
475
476
477
478
479
                row = inputRow;
                inputRow = null;
            } else {
                do {
                    row = cursor.next();
                } while ((row != null) && !outputRowTypes.contains(row.rowType()));
                if (row == null) {
                    if (keepInput && !inputPrecedesBranch) {
                        assert inputRow != null;
                        row = inputRow;
                        inputRow = null;
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
                Row row;
                do {
                    row = input.next();
                    if (row == null) {
                        setIdle();
                    } else if (!keepTypes.contains(row.rowType())) {
                        row = null;
                    }
                } while (row == null && isActive());
                if (LOG_EXECUTION) {
                    LOG.debug("Filter_Default: yield {}", row);
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
        @Override
        public void open()
        {
            super.open();
            Row row = bindings.getRow(bindingPosition);
            assert (row.rowType() == outerType) : row;
            boundRow = row;
        }

        @Override
        public Row next()
View Full Code Here
210
211
212
213
214
215
216
217
218
219
220
                if (CURSOR_LIFECYCLE_ENABLED) {
                    CursorLifecycle.checkIdleOrActive(this);
                }
                checkQueryCancelation();
                Row row = input.next();
                if ((row != null) && (row.rowType() == inputType)) {
                    row = new ProductRow(productType, boundRow, row);
                }
                if (LOG_EXECUTION) {
                    LOG.debug("Product_Nested: yield {}", row);
                }
View Full Code Here
409
410
411
412
413
414
415
416
417
418
419
            lookupState = LookupState.BEFORE;
            lookupRow = null;
            lookupCursor.close();
            Row currentInputRow = input.next();
            if (currentInputRow != null) {
                if (currentInputRow.rowType() == inputRowType) {
                    lookupRow = null;
                    computeLookupRowHKey(currentInputRow);
                    lookupCursor.rebind(lookupRowHKey, true);
                    lookupCursor.open();
                }
View Full Code Here
351
352
353
354
355
356
357
358
359
360
361
            Operator plan = indexScan_Default(latLonIndexRowType, box, lookaheadQuantum());
            Cursor cursor = API.cursor(plan, queryContext, queryBindings);
            cursor.openTopLevel();
            Row row;
            while ((row = cursor.next()) != null) {
                assertSame(latLonIndexRowType.physicalRowType(), row.rowType());
                long z = getLong(row, 0);
                Integer expectedId = zToId.get(z);
                assertNotNull(expectedId);
                int id = getLong(row, 1).intValue();
                assertEquals(expectedId.intValue(), id);
View Full Code Here
414
415
416
417
418
419
420
421
422
423
424
            Operator plan = indexScan_Default(latLonIndexRowType, box, lookaheadQuantum());
            Cursor cursor = API.cursor(plan, queryContext, queryBindings);
            cursor.openTopLevel();
            Row row;
            while ((row = cursor.next()) != null) {
                assertSame(latLonIndexRowType.physicalRowType(), row.rowType());
                long z = getLong(row, 0);
                Integer expectedId = zToId.get(z);
                assertNotNull(expectedId);
                int id = getLong(row, 1).intValue();
                assertEquals(expectedId.intValue(), id);
View Full Code Here
479
480
481
482
483
484
485
486
487
488
489
                Operator plan = indexScan_Default(beforeLatLonIndexRowType, box, lookaheadQuantum());
                Cursor cursor = API.cursor(plan, queryContext, queryBindings);
                cursor.openTopLevel();
                Row row;
                while ((row = cursor.next()) != null) {
                    assertSame(beforeLatLonIndexRowType.physicalRowType(), row.rowType());
                    int rowBefore = getLong(row, 0).intValue();
                    long z = getLong(row, 1);
                    Integer expectedId = zToId.get(z);
                    assertNotNull(expectedId);
                    int rowId = getLong(row, 2).intValue();
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.