Package com.foundationdb.server.error

Examples of com.foundationdb.server.error.AkibanInternalException


    @Override
    public void packRowData(FDBStore store, Session session,
                            FDBStoreData storeData, RowData rowData) {
        RowDef rowDef = rowDefFromId(((Group)object).getRoot(), rowData.getRowDefId());
        if (rowDef == null) {
            throw new AkibanInternalException("Cannot find table " + rowData);
        }
        RowDataValueSource valueSource = new RowDataValueSource();
        int nfields = rowDef.getFieldCount();
        Map<String,Object> value = new HashMap<>(nfields); // Intermediate form of value.
        for (int i = 0; i < nfields; i++) {
View Full Code Here


            break;
        case RIGHT:
            joinType = JoinType.LEFT;
            break;
        default:
            throw new AkibanInternalException("Cannot reverse " + joinType + " join");
        }
        Joinable temp = left;
        left = right;
        right = temp;
    }
View Full Code Here

        driver = new JDBCDriver(reqs);
        try {
            driver.register();
        }
        catch (SQLException ex) {
            throw new AkibanInternalException("Cannot register with JDBC", ex);
        }
    }
View Full Code Here

            }
            catch (UnsupportedEncodingException ex) {
                throw new UnsupportedCharsetException(encoding);
            }
            catch (IOException ex) {
                throw new AkibanInternalException("IO error reading from byte array", ex);
            }
        }
        TCast cast = typesRegistryService.getCastsResolver().cast(source.getType(), targetType);
        TExecutionContext context =
                new TExecutionContext(Collections.singletonList(source.getType()),
View Full Code Here

        case 4:
            return new Value(MNumeric.INT.instance(false), getDataStream(encoded).readInt());
        case 8:
            return new Value(MNumeric.BIGINT.instance(false), getDataStream(encoded).readLong());
        default:
            throw new AkibanInternalException("Not an integer size: " + encoded);
        }
    }
View Full Code Here

            try {
                if (!propertySet(key, properties.getProperty(key)))
                    sessionChanged();
            }
            catch (InvalidOperationException ex2) {
                throw new AkibanInternalException("Error recovering " + key + " setting",
                                                  ex2);
            }
            throw ex;
        }
    }
View Full Code Here

                    found = true;
                    break;
                }
            }
            if (!found) {
                throw new AkibanInternalException("Not a child ordinal " + hkey);
            }
        }
    }
View Full Code Here

            break;
        case SUM_SQUARE:
            sum += x * x;
            break;
        default:
            throw new AkibanInternalException("Aggregator for " + displayName() + " should have been optimized out");
        }
        state.putDouble(sum);
    }
View Full Code Here

        else {
            try {
                results = searcher.search(query, limit, SORT);
            }
            catch (IOException ex) {
                throw new AkibanInternalException("Error searching index", ex);
            }
        }
        position = 0;
    }
View Full Code Here

        Document doc;
        try {
            doc = searcher.doc(results.scoreDocs[position++].doc);
        }
        catch (IOException ex) {
            throw new AkibanInternalException("Error reading document", ex);
        }
        Row row = toHkeyRow(doc.get(IndexedField.KEY_FIELD));
        logger.debug("FullTextCursor: yield {}", row);
        return row;
    }
View Full Code Here

TOP

Related Classes of com.foundationdb.server.error.AkibanInternalException

Copyright © 2018 www.massapicom. 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.