Examples of addSchema()

Examples of com.alibaba.wasp.meta.TableSchemaCacheReader.addSchema()

65
66
67
68
69
70
71
72
73
74
75
    Plan plan = context.getPlan();
    if (plan instanceof CreateTablePlan) {
      CreateTablePlan createPlan = (CreateTablePlan) plan;
      table = createPlan.getTable();
      TableSchemaCacheReader.getService(conf).createTable(table);
      reader.addSchema(table.getTableName(), table);
    }
    EntityGroupInfo egi = new EntityGroupInfo(table.getTableName(), null, null);
    MockFServerServices service = new MockFServerServices();
    eg = new EntityGroup(conf, egi, table, service);
    NullStorageServices storageServices = new NullStorageServices();
View Full Code Here

Examples of com.alibaba.wasp.meta.TableSchemaCacheReader.addSchema()

88
89
90
91
92
93
94
95
96
97
98
          CreateTablePlan createTable = (CreateTablePlan) plan;
          FTable ftable = createTable.getTable();
          fmetaServices.createTable(ftable);
          TableSchemaCacheReader reader = TableSchemaCacheReader
              .getInstance(fmetaServices.getConf());
          reader.addSchema(ftable.getTableName(), ftable);
        }
      } catch (IOException ioe) {
        ioe.printStackTrace();
      }
    }
View Full Code Here

Examples of com.alibaba.wasp.meta.TableSchemaCacheReader.addSchema()

106
107
108
109
110
111
112
113
114
115
116
      Plan plan = context.getPlan();
      if (plan instanceof CreateTablePlan) {
        CreateTablePlan createPlan = (CreateTablePlan) plan;
        table[i] = createPlan.getTable();
        TableSchemaCacheReader.getService(conf).createTable(table[i]);
        reader.addSchema(table[i].getTableName(), table[i]);
      }
    }
    for (int i = 0; i < DruidParserTestUtil.INDEX_SEED.length; i++) {
      String createIndex = DruidParserTestUtil.INDEX_SEED[i];
      context.setSql(createIndex);
View Full Code Here

Examples of com.alibaba.wasp.meta.TableSchemaCacheReader.addSchema()

82
83
84
85
86
87
88
89
90
91
92
        SQLStatement stmt = context.getStmt();
        if (stmt instanceof SQLSelectStatement) {
          MemFMetaStore fmetaServices = new MemFMetaStore();
          TableSchemaCacheReader reader = TableSchemaCacheReader.getInstance(
              conf, fmetaServices);
          reader.addSchema(table.getTableName(), table);
          MetaEventOperation metaEventOperation = new FMetaEventOperation(
              reader);

          SQLSelectStatement sqlSelectStatement = (SQLSelectStatement) stmt;
          // this is SELECT clause
View Full Code Here

Examples of com.bazaarvoice.commons.data.model.json.schema.types.JSONSchemaUnionType.addSchema()

455
456
457
458
459
460
461
462
463
464
465
                if (unionType == null) {
                    unionType = new JSONSchemaUnionType();
                    types.add(unionType);
                }

                unionType.addSchema(fromJSONObject((JSONObject) jsonValue));
            } else {
                types.add(convertSchemaTypeFromJSONTypeValue(jsonValue.toString()));
            }
        }
        return types;
View Full Code Here

Examples of com.impetus.kundera.rest.dto.SchemaMetadata.addSchema()

107
108
109
110
111
112
113
114
115
116
117
                    table.setTableName(m.getTableName());
                    table.setSimpleEntityClassName(m.getEntityClazz().getSimpleName());

                    schema.addTable(table);
                }
                schemaMetadata.addSchema(schema);
            }
        }

        if (schemaMetadata.getSchemaList().isEmpty()) {
            if (log.isDebugEnabled())
View Full Code Here

Examples of com.volantis.mcs.xml.schema.compiler.SchemaCompiler.addSchema()

41
42
43
44
45
46
47
48
49
50
51
    private CompiledSchema COMPILED_SCHEMA;

    protected ModelValidationTestAbstract(Schema schema) {
        SchemaCompiler compiler =
                SCHEMA_COMPILER_FACTORY.createSchemaCompiler();
        compiler.addSchema(schema);
        COMPILED_SCHEMA = compiler.getCompiledSchema();
    }

    protected static class TestElements {
View Full Code Here

Examples of com.volantis.xml.schema.validator.SchemaValidator.addSchema()

139
140
141
142
143
144
145
146
147
148
149
            String expectedString = readAsString(expected);
            String actualString = output.toString();

            // Create the validator.
            SchemaValidator schemaValidator = new SchemaValidator();
            schemaValidator.addSchema(PolicySchemas.MARLIN_LPDM_V3_0);
            schemaValidator.addSchemata(PolicySchemas.MARLIN_RPDM_DTDS);
            schemaValidator.addSchemata(PolicySchemas.REPOSITORY_2005_09);
            schemaValidator.addSchemata(PolicySchemas.REPOSITORY_2005_12);
            schemaValidator.addSchemata(PolicySchemas.REPOSITORY_2006_02);
View Full Code Here

Examples of cz.startnet.utils.pgdiff.schema.PgDatabase.addSchema()

18
19
20
21
22
23
24
25
26
27
28
    @Test(timeout = 1000)
    public void testParseSchemaBothQuoted() {
        final PgDatabase database = new PgDatabase();
        final PgSchema schema = new PgSchema("juzz_system");
        database.addSchema(schema);

        Assert.assertThat(ParserUtils.getSchemaName(
                "\"juzz_system\".\"f_obj_execute_node_select\"", database),
                IsEqual.equalTo("juzz_system"));
    }
View Full Code Here

Examples of nexj.core.meta.integration.format.xml.schema.SchemaUniverse.addSchema()

76
77
78
79
80
81
82
83
84
85
86
      Set excludedSchemaSet = new HashHolder();

      excludedSchemaSet.add(tnsSchema);
      excludedSchemaSet.add(soapBindSchema);
      excludedSchemaSet.add(XSDSchema.XSD);
      universe.addSchema(XSDSchema.XSD);
      universe.resolvePrefixes();

      String sTNSPrefix = universe.getPrefix(tnsSchema);
      String sSOAPBindPrefix = universe.getPrefix(soapBindSchema);
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.