com.mapd.parser.server.CalciteParserFactory Class Reference

Inheritance diagram for com.mapd.parser.server.CalciteParserFactory:

Collaboration diagram for com.mapd.parser.server.CalciteParserFactory:

Public Member Functions
	CalciteParserFactory (String dataDir, final Map< String, ExtensionFunction > extSigs, int dbPort, SockTransportProperties skT)
void	updateOperatorTable ()
Object	makeObject () throws Exception
void	destroyObject (Object obj) throws Exception
boolean	validateObject (Object obj)
void	activateObject (Object obj) throws Exception
void	passivateObject (Object obj) throws Exception

Static Package Functions
	[static initializer]

Static Package Attributes
static final Logger	HEAVYDBLOGGER = LoggerFactory.getLogger(CalciteParserFactory.class)

Private Attributes
final String	dataDir
final Map< String, ExtensionFunction >	extSigs
final int	dbPort
final SockTransportProperties	socket_transport_properties
volatile HeavyDBSqlOperatorTable	tableOperator
final Supplier < HeavyDBSqlOperatorTable >	tableOperatorSupplier

Detailed Description

Definition at line 32 of file CalciteParserFactory.java.

Constructor & Destructor Documentation

com.mapd.parser.server.CalciteParserFactory.CalciteParserFactory ( String  dataDir, final Map< String, ExtensionFunction >  extSigs, int  dbPort, SockTransportProperties  skT  )

inline

Definition at line 57 of file CalciteParserFactory.java.

References com.mapd.parser.server.CalciteParserFactory.dataDir, com.mapd.parser.server.CalciteParserFactory.dbPort, com.mapd.parser.server.CalciteParserFactory.extSigs, and com.mapd.parser.server.CalciteParserFactory.updateOperatorTable().

                                       {
    this.dataDir = dataDir;
    this.extSigs = extSigs;
    this.dbPort = dbPort;
    this.socket_transport_properties = skT;

    updateOperatorTable();
  }

Here is the call graph for this function:

Member Function Documentation

com.mapd.parser.server.CalciteParserFactory.[static initializer] ( )

inlinestaticpackage

void com.mapd.parser.server.CalciteParserFactory.activateObject ( Object  obj ) throws Exception

inline

Definition at line 100 of file CalciteParserFactory.java.

                                                          {
    // don't need to do anything
  }

void com.mapd.parser.server.CalciteParserFactory.destroyObject ( Object  obj ) throws Exception

inline

Definition at line 84 of file CalciteParserFactory.java.

                                                         {
    // no need to do anything
  }

Object com.mapd.parser.server.CalciteParserFactory.makeObject ( ) throws Exception

inline

Definition at line 77 of file CalciteParserFactory.java.

References com.mapd.parser.server.CalciteParserFactory.dataDir, com.mapd.parser.server.CalciteParserFactory.dbPort, com.mapd.parser.server.CalciteParserFactory.socket_transport_properties, and com.mapd.parser.server.CalciteParserFactory.tableOperatorSupplier.

                                              {
    HeavyDBParser obj = new HeavyDBParser(
            dataDir, tableOperatorSupplier, dbPort, socket_transport_properties);
    return obj;
  }

void com.mapd.parser.server.CalciteParserFactory.passivateObject ( Object  obj ) throws Exception

inline

Definition at line 105 of file CalciteParserFactory.java.

                                                           {
    // nothing to currently do here
  }

void com.mapd.parser.server.CalciteParserFactory.updateOperatorTable ( )

inline

Definition at line 69 of file CalciteParserFactory.java.

References com.mapd.parser.server.CalciteParserFactory.extSigs, and com.mapd.parser.server.CalciteParserFactory.tableOperator.

Referenced by com.mapd.parser.server.CalciteParserFactory.CalciteParserFactory().

                                    {
    HeavyDBSqlOperatorTable tableOperator =
            new HeavyDBSqlOperatorTable(SqlStdOperatorTable.instance());
    tableOperator.addUDF(extSigs);
    this.tableOperator = tableOperator;
  }

Here is the caller graph for this function:

boolean com.mapd.parser.server.CalciteParserFactory.validateObject ( Object  obj )

inline

Definition at line 89 of file CalciteParserFactory.java.

References com.mapd.calcite.parser.HeavyDBParser.getCallCount().

                                            {
    HeavyDBParser mdp = (HeavyDBParser) obj;
    if (mdp.getCallCount() < 1000) {
      return true;
    } else {
      HEAVYDBLOGGER.debug(" invalidating object due to max use count");
      return false;
    }
  }

Here is the call graph for this function:

Member Data Documentation

final String com.mapd.parser.server.CalciteParserFactory.dataDir

private

Definition at line 35 of file CalciteParserFactory.java.

Referenced by com.mapd.parser.server.CalciteParserFactory.CalciteParserFactory(), and com.mapd.parser.server.CalciteParserFactory.makeObject().

final int com.mapd.parser.server.CalciteParserFactory.dbPort

private

Definition at line 37 of file CalciteParserFactory.java.

Referenced by com.mapd.parser.server.CalciteParserFactory.CalciteParserFactory(), and com.mapd.parser.server.CalciteParserFactory.makeObject().

final Map<String, ExtensionFunction> com.mapd.parser.server.CalciteParserFactory.extSigs

private

Definition at line 36 of file CalciteParserFactory.java.

Referenced by com.mapd.parser.server.CalciteParserFactory.CalciteParserFactory(), and com.mapd.parser.server.CalciteParserFactory.updateOperatorTable().

final Logger com.mapd.parser.server.CalciteParserFactory.HEAVYDBLOGGER = LoggerFactory.getLogger(CalciteParserFactory.class)

staticpackage

Definition at line 33 of file CalciteParserFactory.java.

final SockTransportProperties com.mapd.parser.server.CalciteParserFactory.socket_transport_properties

private

Definition at line 38 of file CalciteParserFactory.java.

Referenced by com.mapd.parser.server.CalciteParserFactory.makeObject().

volatile HeavyDBSqlOperatorTable com.mapd.parser.server.CalciteParserFactory.tableOperator

private

Definition at line 39 of file CalciteParserFactory.java.

Referenced by com.mapd.parser.server.CalciteParserFactory.updateOperatorTable().

final Supplier<HeavyDBSqlOperatorTable> com.mapd.parser.server.CalciteParserFactory.tableOperatorSupplier

private

Initial value:

=
          new Supplier<HeavyDBSqlOperatorTable>() {
            @Override
            public HeavyDBSqlOperatorTable get() {
              return tableOperator;
            }
          }

Definition at line 40 of file CalciteParserFactory.java.

Referenced by com.mapd.parser.server.CalciteParserFactory.makeObject().

---

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/parser/server/CalciteParserFactory.java