Examples of com.foundationdb.qp.rowtype.RowType.table()

com.foundationdb.qp.rowtype.RowType.table()

Get the one user table that this row type corresponds to. Not all row types correspond to one user table; a flattened row doesn't, nor does a row type that adds fields. For instance, the final row type for a query {@code SELECT cid FROM customer} may (but does not have to) have a corresponding Table; the row typefor {@code SELECT 1, cid FROM customer} may not, since the first field doesn't correspond to any columnin the {@code customer} table.

If this row type doesn't correspond to a user table, it will throw an exception. You can test for that using {@linkplain #hasTable()}. If that method returns true, this method may not throw an exception.

If this method doesn't throw an exception, several other things must be true:

{@code fieldHasColumn(n) == true} for {@code 0 <= n < nFields()}
{@code fieldColumn(n).getTable() == table()} (for same range of {@code n}

@return the user table associated with this row @throws RowTypeToTableMappingException if there is no user table associated with this row

                if(row != null) {
                    RowType rowType = row.rowType();
                    HKeyChecker checker = checkers.get(rowType);
                    if (checker == null) {
                        if (rowType.hasTable()) {
                            checker = new SchemaManagerChecker(rowType.table().getTableId());
                        } else {
                            checker = new FalseChecker();
                        }
                        checkers.put(row.rowType(), checker);
                    }

            AkibanInformationSchema oldAIS = schemaManager.getAis(session);
            Schema oldSchema = SchemaCache.globalSchema(oldAIS);
            Multimap<Group,RowType> groupMap = HashMultimap.create();
            for(ChangeSet cs : changeSets) {
                RowType rowType = oldSchema.tableRowType(cs.getTableId());
                groupMap.put(rowType.table().getGroup(), rowType);
            }
            // Scan all affected groups
            StoreAdapter adapter = store.createAdapter(session, oldSchema);
            final TransformCache transformCache = getTransformCache(session, null);
            for(Entry<Group, Collection<RowType>> entry : groupMap.asMap().entrySet()) {

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.