OmniSciDB  b28c0d5765
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
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().

60  {
61  this.dataDir = dataDir;
62  this.extSigs = extSigs;
63  this.dbPort = dbPort;
64  this.socket_transport_properties = skT;
65 
67  }
final Map< String, ExtensionFunction > extSigs

+ 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.

100  {
101  // don't need to do anything
102  }
void com.mapd.parser.server.CalciteParserFactory.destroyObject ( Object  obj) throws Exception
inline

Definition at line 84 of file CalciteParserFactory.java.

84  {
85  // no need to do anything
86  }
void com.mapd.parser.server.CalciteParserFactory.passivateObject ( Object  obj) throws Exception
inline

Definition at line 105 of file CalciteParserFactory.java.

105  {
106  // nothing to currently do here
107  }
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().

69  {
70  HeavyDBSqlOperatorTable tableOperator =
71  new HeavyDBSqlOperatorTable(SqlStdOperatorTable.instance());
72  tableOperator.addUDF(extSigs);
73  this.tableOperator = tableOperator;
74  }
volatile HeavyDBSqlOperatorTable tableOperator
final Map< String, ExtensionFunction > extSigs

+ 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().

89  {
90  HeavyDBParser mdp = (HeavyDBParser) obj;
91  if (mdp.getCallCount() < 1000) {
92  return true;
93  } else {
94  HEAVYDBLOGGER.debug(" invalidating object due to max use count");
95  return false;
96  }
97  }

+ Here is the call graph for this function:

Member Data Documentation

final String com.mapd.parser.server.CalciteParserFactory.dataDir
private
final int com.mapd.parser.server.CalciteParserFactory.dbPort
private
final Map<String, ExtensionFunction> com.mapd.parser.server.CalciteParserFactory.extSigs
private
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
volatile HeavyDBSqlOperatorTable com.mapd.parser.server.CalciteParserFactory.tableOperator
private
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: