com.mapd.calcite.planner.tester Class Reference

Collaboration diagram for com.mapd.calcite.planner.tester:

Static Public Member Functions
static void	main (String[] args)

Static Package Attributes
static final org.slf4j.Logger	MAPDLOGGER = LoggerFactory.getLogger(tester.class)

Detailed Description

Author

michael

Definition at line 33 of file tester.java.

Member Function Documentation

main()

static void com.mapd.calcite.planner.tester.main ( String []  args )

inlinestatic

Definition at line 36 of file tester.java.

References com.mapd.calcite.parser.MapDParser.getRelAlgebra(), com.mapd.calcite.planner.tester.MAPDLOGGER, com.mapd.calcite.parser.MapDParser.setUser(), and com.mapd.calcite.parser.MapDSerializer.toString().

                                         {
    final SqlStdOperatorTable stdOpTab = SqlStdOperatorTable.instance();
    // SqlOperatorTable opTab =
    // ChainedSqlOperatorTable.of(stdOpTab,
    // new ListSqlOperatorTable(
    // ImmutableList.<SqlOperator>of(new MyCountAggFunction())));
    MapDUser mdu = new MapDUser("admin", "passwd", "catalog", -1);
    MapDSchema mapd =
            new MapDSchema("/home/michael/mapd2/build/data", null, -1, mdu, null);
    final SchemaPlus rootSchema = Frameworks.createRootSchema(true);
    final FrameworkConfig config = Frameworks.newConfigBuilder()
                                           .defaultSchema(rootSchema.add("omnisci", mapd))
                                           .operatorTable(stdOpTab)
                                           .build();

    Planner p = Frameworks.getPlanner(config);

    SqlNode parseR = null;
    try {
      parseR = p.parse("select * from customer where c_custkey = 1.345000 limit 5");
    } catch (SqlParseException ex) {
      Logger.getLogger(tester.class.getName()).log(Level.SEVERE, null, ex);
    }

    SqlNode validateR = null;
    try {
      p.validate(parseR);
    } catch (ValidationException ex) {
      Logger.getLogger(tester.class.getName()).log(Level.SEVERE, null, ex);
    }
    RelRoot relR = null;
    try {
      relR = p.rel(validateR);
    } catch (RelConversionException ex) {
      Logger.getLogger(tester.class.getName()).log(Level.SEVERE, null, ex);
    }
    MAPDLOGGER.error("Result was " + relR);
    MAPDLOGGER.error("Result project() " + relR.project());
    MAPDLOGGER.error("Result project() " + RelOptUtil.toString(relR.project()));
    MAPDLOGGER.error("Json Version \n" + MapDSerializer.toString(relR.project()));

    // now do with MapD parser
    MapDParser mp = new MapDParser("/home/michael/mapd2/build/data", null, -1, null);
    mp.setUser(mdu);

    try {
      MapDParserOptions mdpo = new MapDParserOptions();
      MAPDLOGGER.error("MapDParser result: \n"
              + mp.getRelAlgebra(
                      "select * from customer where c_custkey = 1.345000 limit 5", mdpo));
    } catch (SqlParseException ex) {
      Logger.getLogger(tester.class.getName()).log(Level.SEVERE, null, ex);
    } catch (ValidationException ex) {
      Logger.getLogger(tester.class.getName()).log(Level.SEVERE, null, ex);
    } catch (RelConversionException ex) {
      Logger.getLogger(tester.class.getName()).log(Level.SEVERE, null, ex);
    }
  }

Here is the call graph for this function:

Member Data Documentation

MAPDLOGGER

final org.slf4j.Logger com.mapd.calcite.planner.tester.MAPDLOGGER = LoggerFactory.getLogger(tester.class)

staticpackage

Definition at line 34 of file tester.java.

Referenced by com.mapd.calcite.planner.tester.main().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/main/java/com/mapd/calcite/planner/tester.java