Examples of rowType()

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

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

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

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

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

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

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

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

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

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

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

515
516
517
518
519
520
521
522
523
524
525
            cursor.openTopLevel();
            Row row;
            long previousDistance = Long.MIN_VALUE;
            int count = 0;
            while ((row = cursor.next()) != null) {
                assertSame(latLonIndexRowType.physicalRowType(), row.rowType());
                long zActual = getLong(row, 0);
                int id = getLong(row, 1).intValue();
                BigDecimal lat = lats.get(id);
                BigDecimal lon = lons.get(id);
                long zExpected = Spatial.shuffle(space, lat.doubleValue(), lon.doubleValue());
View Full Code Here

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

570
571
572
573
574
575
576
577
578
579
580
                cursor.openTopLevel();
                Row row;
                long previousDistance = Long.MIN_VALUE;
                Collection<Integer> actualIdByDistance = new ArrayList<>();
                while ((row = cursor.next()) != null) {
                    assertSame(beforeLatLonIndexRowType.physicalRowType(), row.rowType());
                    int beforeActual = getLong(row, 0).intValue();
                    assertEquals(before, beforeActual);
                    long zActual = getLong(row, 1);
                    int id = getLong(row, 2).intValue();
                    BigDecimal lat = lats.get(id);
View Full Code Here

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

710
711
712
713
714
715
716
717
718
719
720
        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

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

755
756
757
758
759
760
761
762
763
764
765
        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

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

110
111
112
113
114
115
116
117
118
119
120
            PostgresOutputter<Row> outputter = getRowOutputter(context);
            outputter.beforeData();
            if (cursor != null) {
                Row row;
                while ((row = cursor.next()) != null) {
                    assert (getResultRowType() == null) || (row.rowType() == getResultRowType()) : row;
                    outputter.output(row);
                    nrows++;
                    if ((maxrows > 0) && (nrows >= maxrows)) {
                        suspended = true;
                        break;
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.