Examples of net.hydromatic.optiq.SchemaPlus

net.hydromatic.optiq.SchemaPlus
Extension to the {@link Schema} interface.
Given a user-defined schema that implements the {@link Schema} interface,Optiq creates a wrapper that implements the {@code SchemaPlus} interface.This provides extra functionality, such as access to tables that have been added explicitly.

A user-defined schema does not need to implement this interface, but by the time a schema is passed to a method in a user-defined schema or user-defined table, it will have been wrapped in this interface.

    @Override
    public PhysicalPlan getPlan(SqlNode sqlNode) throws ValidationException, RelConversionException, IOException {
      SqlDropView dropView = unwrap(sqlNode, SqlDropView.class);


      try {
        SchemaPlus schema = findSchema(context.getRootSchema(), context.getNewDefaultSchema(), dropView.getSchemaPath());
        AbstractSchema drillSchema = getDrillSchema(schema);


        String schemaPath = drillSchema.getFullSchemaName();
        if (!drillSchema.isMutable()) {
          return DirectPlan.createDirectPlan(context, false, String.format("Schema '%s' is not a mutable schema. " +

View Full Code Here

    DrillFileSystem fs = null;
    String defaultLocation = null;
    String fromDir = "./";


    try {
      SchemaPlus defaultSchema = context.getNewDefaultSchema();
      SchemaPlus drillSchema = defaultSchema;


      // Show files can be used without from clause, in which case we display the files in the default schema
      if (from != null) {
        // We are not sure if the full from clause is just the schema or includes table name, first try to see if the full path specified is a schema
        try {

View Full Code Here

        RelDataType rowType = new DrillFixedRelDataTypeImpl(planner.getTypeFactory(), tblFiledNames);


        relQuery = RelOptUtil.createCastRel(relQuery, rowType, true);
      }


      SchemaPlus schema = findSchema(context.getRootSchema(), context.getNewDefaultSchema(),
          sqlCreateTable.getSchemaPath());


      AbstractSchema drillSchema = getDrillSchema(schema);


      if (!drillSchema.isMutable()) {
        return DirectPlan.createDirectPlan(context, false, String.format("Current schema '%s' is not a mutable schema. " +
            "Can't create tables in this schema.", drillSchema.getFullSchemaName()));
      }


      String newTblName = sqlCreateTable.getName();
      if (schema.getTable(newTblName) != null) {
        return DirectPlan.createDirectPlan(context, false, String.format("Table '%s' already exists.", newTblName));
      }


      log("Optiq Logical", relQuery);

View Full Code Here


      SqlNode fromClause = new SqlIdentifier(
          ImmutableList.of("INFORMATION_SCHEMA", "COLUMNS"), null, SqlParserPos.ZERO, null);


      final SqlIdentifier table = node.getTable();
      final SchemaPlus schema = findSchema(context.getRootSchema(), context.getNewDefaultSchema(),
          Util.skipLast(table.names));
      final String tableName = Util.last(table.names);


      if (schema.getTable(tableName) == null) {
        throw new RelConversionException(String.format("Table %s is not valid", Util.sepList(table.names, ".")));
      }


      SqlNode schemaCondition = null;
      if (!isRootSchema(schema)) {

View Full Code Here


    final StoragePluginRegistry registry = new StoragePluginRegistry(dbContext);
    registry.init();
    final FunctionImplementationRegistry functionRegistry = new FunctionImplementationRegistry(config);
    final DrillOperatorTable table = new DrillOperatorTable(functionRegistry);
    final SchemaPlus root = SimpleOptiqSchema.createRootSchema(false);
    registry.getSchemaFactory().registerSchemas(UserSession.Builder.newBuilder().setSupportComplexTypes(true).build(), root);




    new NonStrictExpectations() {
      {

View Full Code Here

  }


  @Override
  public void registerSchemas(UserSession session, SchemaPlus parent) {
    HiveSchema schema = new HiveSchema(schemaName);
    SchemaPlus hPlus = parent.add(schemaName, schema);
    schema.setHolder(hPlus);
  }

View Full Code Here

    }
    final QueryableTable queryableTable =
        rel.getTable().unwrap(QueryableTable.class);
    if (queryableTable != null) {
      final Type elementType = queryableTable.getElementType();
      SchemaPlus schema = root.getRootSchema();
      for (String name : Util.skipLast(rel.getTable().getQualifiedName())) {
        schema = schema.getSubSchema(name);
      }
      if (elementType instanceof Class) {
        //noinspection unchecked
        final Queryable<Object> queryable = Schemas.queryable(root,
            (Class) elementType, rel.getTable().getQualifiedName());

View Full Code Here

    }
  }


  // OptiqCatalogReader is stateless; no need to store one
  private OptiqCatalogReader createCatalogReader() {
    SchemaPlus rootSchema = rootSchema(defaultSchema);
    return new OptiqCatalogReader(
        OptiqSchema.from(rootSchema),
        caseSensitive,
        OptiqSchema.from(defaultSchema).path(null),
        typeFactory);

View Full Code Here

    if (connection == null) {
      fail(new UnsupportedOperationException("Schema tree can only be created in root fragment. " +
          "This is a non-root fragment."));
      return null;
    } else {
      SchemaPlus root = SimpleOptiqSchema.createRootSchema(false);
      context.getStorage().getSchemaFactory().registerSchemas(connection.getSession(), root);
      return root;
    }
  }

View Full Code Here

  public UserSession getSession(){
    return session;
  }


  public SchemaPlus getNewDefaultSchema(){
    SchemaPlus rootSchema = getRootSchema();
    SchemaPlus defaultSchema = session.getDefaultSchema(rootSchema);
    if(defaultSchema == null){
      return rootSchema;
    }else{
      return defaultSchema;
    }

View Full Code Here

0 1 2 3 4 5 6 7

TOP

Related Classes of net.hydromatic.optiq.SchemaPlus

net.hydromatic.optiq.examples.foodmart.java.JdbcExample

net.hydromatic.optiq.impl.interpreter.ScanNode

net.hydromatic.optiq.impl.splunk.SplunkDriver

net.hydromatic.optiq.prepare.PlannerImpl

net.hydromatic.optiq.test.ExceptionMessageTest

net.hydromatic.optiq.test.LinqFrontJdbcBackTest

net.hydromatic.optiq.test.MultiJdbcSchemaJoinTest

net.hydromatic.optiq.test.ReflectiveSchemaTest

net.hydromatic.optiq.tools.FrameworksTest

net.hydromatic.optiq.tools.PlannerTest

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.