OmniSciDB  29e35f4d58
com.mapd.parser.server.CalciteServerHandler Class Reference
+ Inheritance diagram for com.mapd.parser.server.CalciteServerHandler:
+ Collaboration diagram for com.mapd.parser.server.CalciteServerHandler:

Public Member Functions

void ping () throws TException
 
TPlanResult process (String user, String session, String catalog, String sqlText, java.util.List< TFilterPushDownInfo > thriftFilterPushDownInfo, boolean legacySyntax, boolean isExplain, boolean isViewOptimize) throws InvalidParseRequest, TException
 
void shutdown () throws TException
 
String getExtensionFunctionWhitelist ()
 
String getUserDefinedFunctionWhitelist ()
 
String getRuntimeExtensionFunctionWhitelist ()
 
void updateMetadata (String catalog, String table) throws TException
 
List< TCompletionHint > getCompletionHints (String user, String session, String catalog, List< String > visible_tables, String sql, int cursor) throws TException
 
void setRuntimeExtensionFunctions (List< TUserDefinedFunction > udfs, List< TUserDefinedTableFunction > udtfs)
 

Package Functions

 CalciteServerHandler (int mapdPort, String dataDir, String extensionFunctionsAstFile, SockTransportProperties skT, String udfAstFile)
 
void setServer (TServer s)
 

Package Attributes

Map< String, ExtensionFunctionudfRTSigs = null
 

Static Package Attributes

static final Logger MAPDLOGGER = LoggerFactory.getLogger(CalciteServerHandler.class)
 

Static Private Member Functions

static ExtensionFunction toExtensionFunction (TUserDefinedFunction udf)
 
static ExtensionFunction toExtensionFunction (TUserDefinedTableFunction udtf)
 
static ExtensionFunction.ExtArgumentType toExtArgumentType (TExtArgumentType type)
 
static TCompletionHintType hintTypeToThrift (final SqlMonikerType type)
 

Private Attributes

TServer server
 
final int mapdPort
 
volatile long callCount
 
final GenericObjectPool parserPool
 
final String extSigsJson
 
final String udfSigsJson
 
String udfRTSigsJson = ""
 
SockTransportProperties skT
 
Map< String, ExtensionFunctionextSigs = null
 
String dataDir
 

Detailed Description

Author
michael

Definition at line 60 of file CalciteServerHandler.java.

Constructor & Destructor Documentation

◆ CalciteServerHandler()

com.mapd.parser.server.CalciteServerHandler.CalciteServerHandler ( int  mapdPort,
String  dataDir,
String  extensionFunctionsAstFile,
SockTransportProperties  skT,
String  udfAstFile 
)
inlinepackage

Definition at line 83 of file CalciteServerHandler.java.

References com.mapd.parser.server.CalciteServerHandler.dataDir, com.mapd.parser.server.CalciteServerHandler.mapdPort, com.mapd.parser.server.ExtensionFunctionSignatureParser.parse(), and com.mapd.parser.server.ExtensionFunctionSignatureParser.signaturesToJson().

87  {
88  this.mapdPort = mapdPort;
89  this.dataDir = dataDir;
90 
91  Map<String, ExtensionFunction> udfSigs = null;
92 
93  try {
94  extSigs = ExtensionFunctionSignatureParser.parse(extensionFunctionsAstFile);
95  } catch (IOException ex) {
96  MAPDLOGGER.error(
97  "Could not load extension function signatures: " + ex.getMessage());
98  }
99  extSigsJson = ExtensionFunctionSignatureParser.signaturesToJson(extSigs);
100 
101  try {
102  if (!udfAstFile.isEmpty()) {
103  udfSigs = ExtensionFunctionSignatureParser.parse(udfAstFile);
104  }
105  } catch (IOException ex) {
106  MAPDLOGGER.error("Could not load udf function signatures: " + ex.getMessage());
107  }
108  udfSigsJson = ExtensionFunctionSignatureParser.signaturesToJson(udfSigs);
109 
110  // Put all the udf functions signatures in extSigs so Calcite has a view of
111  // extension functions and udf functions
112  if (!udfAstFile.isEmpty()) {
113  extSigs.putAll(udfSigs);
114  }
115 
116  PoolableObjectFactory parserFactory =
117  new CalciteParserFactory(dataDir, extSigs, mapdPort, skT);
118  // GenericObjectPool::setFactory is deprecated
119  this.parserPool = new GenericObjectPool(parserFactory);
120  }
+ Here is the call graph for this function:

Member Function Documentation

◆ getCompletionHints()

List<TCompletionHint> com.mapd.parser.server.CalciteServerHandler.getCompletionHints ( String  user,
String  session,
String  catalog,
List< String >  visible_tables,
String  sql,
int  cursor 
) throws TException
inline

Definition at line 288 of file CalciteServerHandler.java.

References com.mapd.calcite.parser.MapDParser.getCompletionHints(), com.mapd.parser.server.CalciteServerHandler.hintTypeToThrift(), run_benchmark_import.parser, run_benchmark_import.result, com.mapd.calcite.parser.MapDParser.setUser(), and Experimental.String.

293  {
294  callCount++;
295  MapDParser parser;
296  try {
297  parser = (MapDParser) parserPool.borrowObject();
298  } catch (Exception ex) {
299  String msg = "Could not get Parse Item from pool: " + ex.getMessage();
300  MAPDLOGGER.error(msg);
301  throw new TException(msg);
302  }
303  MapDUser mapDUser = new MapDUser(user, session, catalog, mapdPort);
304  MAPDLOGGER.debug("getCompletionHints was called User: " + user
305  + " Catalog: " + catalog + " sql: " + sql);
306  parser.setUser(mapDUser);
307  CURRENT_PARSER.set(parser);
308 
309  MapDPlanner.CompletionResult completion_result;
310  try {
311  completion_result = parser.getCompletionHints(sql, cursor, visible_tables);
312  } catch (Exception ex) {
313  String msg = "Could not retrieve completion hints: " + ex.getMessage();
314  MAPDLOGGER.error(msg);
315  return new ArrayList<>();
316  } finally {
317  CURRENT_PARSER.set(null);
318  try {
319  // put parser object back in pool for others to use
320  parserPool.returnObject(parser);
321  } catch (Exception ex) {
322  String msg = "Could not return parse object: " + ex.getMessage();
323  MAPDLOGGER.error(msg);
324  throw new InvalidParseRequest(-4, msg);
325  }
326  }
327  List<TCompletionHint> result = new ArrayList<>();
328  for (final SqlMoniker hint : completion_result.hints) {
329  result.add(new TCompletionHint(hintTypeToThrift(hint.getType()),
330  hint.getFullyQualifiedNames(),
331  completion_result.replaced));
332  }
333  return result;
334  }
static TCompletionHintType hintTypeToThrift(final SqlMonikerType type)
+ Here is the call graph for this function:

◆ getExtensionFunctionWhitelist()

String com.mapd.parser.server.CalciteServerHandler.getExtensionFunctionWhitelist ( )
inline

◆ getRuntimeExtensionFunctionWhitelist()

String com.mapd.parser.server.CalciteServerHandler.getRuntimeExtensionFunctionWhitelist ( )
inline

◆ getUserDefinedFunctionWhitelist()

String com.mapd.parser.server.CalciteServerHandler.getUserDefinedFunctionWhitelist ( )
inline

◆ hintTypeToThrift()

static TCompletionHintType com.mapd.parser.server.CalciteServerHandler.hintTypeToThrift ( final SqlMonikerType  type)
inlinestaticprivate

Definition at line 444 of file CalciteServerHandler.java.

References TABLE.

Referenced by com.mapd.parser.server.CalciteServerHandler.getCompletionHints().

444  {
445  switch (type) {
446  case COLUMN:
447  return TCompletionHintType.COLUMN;
448  case TABLE:
449  return TCompletionHintType.TABLE;
450  case VIEW:
451  return TCompletionHintType.VIEW;
452  case SCHEMA:
453  return TCompletionHintType.SCHEMA;
454  case CATALOG:
455  return TCompletionHintType.CATALOG;
456  case REPOSITORY:
457  return TCompletionHintType.REPOSITORY;
458  case FUNCTION:
459  return TCompletionHintType.FUNCTION;
460  case KEYWORD:
461  return TCompletionHintType.KEYWORD;
462  default:
463  return null;
464  }
465  }
+ Here is the caller graph for this function:

◆ ping()

void com.mapd.parser.server.CalciteServerHandler.ping ( ) throws TException
inline

Definition at line 123 of file CalciteServerHandler.java.

123  {
124  MAPDLOGGER.debug("Ping hit");
125  }

◆ process()

TPlanResult com.mapd.parser.server.CalciteServerHandler.process ( String  user,
String  session,
String  catalog,
String  sqlText,
java.util.List< TFilterPushDownInfo >  thriftFilterPushDownInfo,
boolean  legacySyntax,
boolean  isExplain,
boolean  isViewOptimize 
) throws InvalidParseRequest, TException
inline

Definition at line 128 of file CalciteServerHandler.java.

References com.mapd.calcite.parser.MapDParser.captureIdentifiers(), com.mapd.calcite.parser.MapDParser.clearMemo(), org.apache.calcite.prepare.SqlIdentifierCapturer.deletes, com.mapd.calcite.parser.MapDParser.getRelAlgebra(), org.apache.calcite.prepare.SqlIdentifierCapturer.inserts, run_benchmark_import.parser, com.mapd.calcite.parser.MapDParser.resolveSelectIdentifiers(), run_benchmark_import.result, org.apache.calcite.prepare.SqlIdentifierCapturer.selects, com.mapd.calcite.parser.MapDParser.setUser(), Experimental.String, and org.apache.calcite.prepare.SqlIdentifierCapturer.updates.

135  {
136  long timer = System.currentTimeMillis();
137  callCount++;
138  MapDParser parser;
139  try {
140  parser = (MapDParser) parserPool.borrowObject();
141  parser.clearMemo();
142  } catch (Exception ex) {
143  String msg = "Could not get Parse Item from pool: " + ex.getMessage();
144  MAPDLOGGER.error(msg);
145  throw new InvalidParseRequest(-1, msg);
146  }
147  MapDUser mapDUser = new MapDUser(user, session, catalog, mapdPort);
148  MAPDLOGGER.debug("process was called User: " + user + " Catalog: " + catalog
149  + " sql: " + sqlText);
150  parser.setUser(mapDUser);
151  CURRENT_PARSER.set(parser);
152 
153  // need to trim the sql string as it seems it is not trimed prior to here
154  sqlText = sqlText.trim();
155  // remove last charcter if it is a ;
156  if (sqlText.length() > 0 && sqlText.charAt(sqlText.length() - 1) == ';') {
157  sqlText = sqlText.substring(0, sqlText.length() - 1);
158  }
159  String relAlgebra;
160  SqlIdentifierCapturer capturer;
161  TAccessedQueryObjects primaryAccessedObjects = new TAccessedQueryObjects();
162  TAccessedQueryObjects resolvedAccessedObjects = new TAccessedQueryObjects();
163  try {
164  final List<MapDParserOptions.FilterPushDownInfo> filterPushDownInfo =
165  new ArrayList<>();
166  for (final TFilterPushDownInfo req : thriftFilterPushDownInfo) {
167  filterPushDownInfo.add(new MapDParserOptions.FilterPushDownInfo(
168  req.input_prev, req.input_start, req.input_next));
169  }
170  try {
171  MapDParserOptions parserOptions = new MapDParserOptions(
172  filterPushDownInfo, legacySyntax, isExplain, isViewOptimize);
173  relAlgebra = parser.getRelAlgebra(sqlText, parserOptions);
174  } catch (ValidationException ex) {
175  String msg = "Validation: " + ex.getMessage();
176  MAPDLOGGER.error(msg);
177  throw ex;
178  } catch (RelConversionException ex) {
179  String msg = " RelConversion failed: " + ex.getMessage();
180  MAPDLOGGER.error(msg);
181  throw ex;
182  }
183  capturer = parser.captureIdentifiers(sqlText, legacySyntax);
184 
185  primaryAccessedObjects.tables_selected_from = new ArrayList<>(capturer.selects);
186  primaryAccessedObjects.tables_inserted_into = new ArrayList<>(capturer.inserts);
187  primaryAccessedObjects.tables_updated_in = new ArrayList<>(capturer.updates);
188  primaryAccessedObjects.tables_deleted_from = new ArrayList<>(capturer.deletes);
189 
190  // also resolve all the views in the select part
191  // resolution of the other parts is not
192  // necessary as these cannot be views
193  resolvedAccessedObjects.tables_selected_from =
194  new ArrayList<>(parser.resolveSelectIdentifiers(capturer));
195  resolvedAccessedObjects.tables_inserted_into = new ArrayList<>(capturer.inserts);
196  resolvedAccessedObjects.tables_updated_in = new ArrayList<>(capturer.updates);
197  resolvedAccessedObjects.tables_deleted_from = new ArrayList<>(capturer.deletes);
198 
199  } catch (SqlParseException ex) {
200  String msg = "Parse failed: " + ex.getMessage();
201  MAPDLOGGER.error(msg);
202  throw new InvalidParseRequest(-2, msg);
203  } catch (CalciteContextException ex) {
204  String msg = "Validate failed: " + ex.getMessage();
205  MAPDLOGGER.error(msg);
206  throw new InvalidParseRequest(-3, msg);
207  } catch (Throwable ex) {
208  String msg = "Exception occurred: " + ex.getMessage();
209  MAPDLOGGER.error(msg);
210  throw new InvalidParseRequest(-4, msg);
211  } finally {
212  CURRENT_PARSER.set(null);
213  try {
214  // put parser object back in pool for others to use
215  parserPool.returnObject(parser);
216  } catch (Exception ex) {
217  String msg = "Could not return parse object: " + ex.getMessage();
218  MAPDLOGGER.error(msg);
219  throw new InvalidParseRequest(-4, msg);
220  }
221  }
222 
223  TPlanResult result = new TPlanResult();
224  result.primary_accessed_objects = primaryAccessedObjects;
225  result.resolved_accessed_objects = resolvedAccessedObjects;
226  result.plan_result = relAlgebra;
227  result.execution_time_ms = System.currentTimeMillis() - timer;
228 
229  return result;
230  }
+ Here is the call graph for this function:

◆ setRuntimeExtensionFunctions()

void com.mapd.parser.server.CalciteServerHandler.setRuntimeExtensionFunctions ( List< TUserDefinedFunction >  udfs,
List< TUserDefinedTableFunction >  udtfs 
)
inline

Definition at line 337 of file CalciteServerHandler.java.

References com.mapd.parser.server.ExtensionFunctionSignatureParser.signaturesToJson(), Experimental.String, and com.mapd.parser.server.CalciteServerHandler.toExtensionFunction().

338  {
339  // Clean up previously defined Runtime UDFs
340  if (udfRTSigs != null) {
341  for (String name : udfRTSigs.keySet()) extSigs.remove(name);
342  udfRTSigsJson = "";
343  udfRTSigs.clear();
344  } else {
345  udfRTSigs = new HashMap<String, ExtensionFunction>();
346  }
347 
348  for (TUserDefinedFunction udf : udfs) {
349  udfRTSigs.put(udf.name, toExtensionFunction(udf));
350  }
351 
352  for (TUserDefinedTableFunction udtf : udtfs) {
353  udfRTSigs.put(udtf.name, toExtensionFunction(udtf));
354  }
355 
356  // Avoid overwritting compiled and Loadtime UDFs:
357  for (String name : udfRTSigs.keySet()) {
358  if (extSigs.containsKey(name)) {
359  MAPDLOGGER.error("Extension function `" + name
360  + "` exists. Skipping runtime extenension function with the same name.");
361  udfRTSigs.remove(name);
362  }
363  }
364 
365  udfRTSigsJson = ExtensionFunctionSignatureParser.signaturesToJson(udfRTSigs);
366  // Expose RT UDFs to Calcite server:
367  extSigs.putAll(udfRTSigs);
368  }
Map< String, ExtensionFunction > udfRTSigs
static ExtensionFunction toExtensionFunction(TUserDefinedFunction udf)
+ Here is the call graph for this function:

◆ setServer()

void com.mapd.parser.server.CalciteServerHandler.setServer ( TServer  s)
inlinepackage

Definition at line 254 of file CalciteServerHandler.java.

Referenced by com.mapd.parser.server.CalciteServerWrapper.startServer().

+ Here is the caller graph for this function:

◆ shutdown()

void com.mapd.parser.server.CalciteServerHandler.shutdown ( ) throws TException
inline

Definition at line 233 of file CalciteServerHandler.java.

233  {
234  // received request to shutdown
235  MAPDLOGGER.debug("Shutdown calcite java server");
236  server.stop();
237  }

◆ toExtArgumentType()

static ExtensionFunction.ExtArgumentType com.mapd.parser.server.CalciteServerHandler.toExtArgumentType ( TExtArgumentType  type)
inlinestaticprivate

Definition at line 391 of file CalciteServerHandler.java.

References com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayDouble, ArrayDouble, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayFloat, ArrayFloat, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayInt16, ArrayInt16, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayInt32, ArrayInt32, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayInt64, ArrayInt64, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.ArrayInt8, ArrayInt8, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Bool, Bool, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Cursor, Cursor, Double, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Double, Float, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Float, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.GeoPoint, GeoPoint, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Int16, Int16, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Int32, Int32, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Int64, Int64, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Int8, Int8, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.PDouble, PDouble, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.PFloat, PFloat, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.PInt16, PInt16, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.PInt32, PInt32, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.PInt64, PInt64, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.PInt8, PInt8, com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Void, and Void.

Referenced by com.mapd.parser.server.CalciteServerHandler.toExtensionFunction().

392  {
393  switch (type) {
394  case Int8:
395  return ExtensionFunction.ExtArgumentType.Int8;
396  case Int16:
397  return ExtensionFunction.ExtArgumentType.Int16;
398  case Int32:
399  return ExtensionFunction.ExtArgumentType.Int32;
400  case Int64:
401  return ExtensionFunction.ExtArgumentType.Int64;
402  case Float:
403  return ExtensionFunction.ExtArgumentType.Float;
404  case Double:
405  return ExtensionFunction.ExtArgumentType.Double;
406  case Void:
407  return ExtensionFunction.ExtArgumentType.Void;
408  case PInt8:
409  return ExtensionFunction.ExtArgumentType.PInt8;
410  case PInt16:
411  return ExtensionFunction.ExtArgumentType.PInt16;
412  case PInt32:
413  return ExtensionFunction.ExtArgumentType.PInt32;
414  case PInt64:
415  return ExtensionFunction.ExtArgumentType.PInt64;
416  case PFloat:
417  return ExtensionFunction.ExtArgumentType.PFloat;
418  case PDouble:
419  return ExtensionFunction.ExtArgumentType.PDouble;
420  case Bool:
421  return ExtensionFunction.ExtArgumentType.Bool;
422  case ArrayInt8:
423  return ExtensionFunction.ExtArgumentType.ArrayInt8;
424  case ArrayInt16:
425  return ExtensionFunction.ExtArgumentType.ArrayInt16;
426  case ArrayInt32:
427  return ExtensionFunction.ExtArgumentType.ArrayInt32;
428  case ArrayInt64:
429  return ExtensionFunction.ExtArgumentType.ArrayInt64;
430  case ArrayFloat:
431  return ExtensionFunction.ExtArgumentType.ArrayFloat;
432  case ArrayDouble:
433  return ExtensionFunction.ExtArgumentType.ArrayDouble;
434  case GeoPoint:
435  return ExtensionFunction.ExtArgumentType.GeoPoint;
436  case Cursor:
437  return ExtensionFunction.ExtArgumentType.Cursor;
438  default:
439  MAPDLOGGER.error("toExtArgumentType: unknown type " + type);
440  return null;
441  }
442  }
+ Here is the caller graph for this function:

◆ toExtensionFunction() [1/2]

static ExtensionFunction com.mapd.parser.server.CalciteServerHandler.toExtensionFunction ( TUserDefinedFunction  udf)
inlinestaticprivate

Definition at line 370 of file CalciteServerHandler.java.

References run_benchmark_import.args, com.mapd.parser.server.CalciteServerHandler.toExtArgumentType(), and com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Void.

Referenced by com.mapd.parser.server.CalciteServerHandler.setRuntimeExtensionFunctions().

370  {
371  List<ExtensionFunction.ExtArgumentType> args =
372  new ArrayList<ExtensionFunction.ExtArgumentType>();
373  for (TExtArgumentType atype : udf.argTypes) {
374  final ExtensionFunction.ExtArgumentType arg_type = toExtArgumentType(atype);
375  if (arg_type != ExtensionFunction.ExtArgumentType.Void) {
376  args.add(arg_type);
377  }
378  }
379  return new ExtensionFunction(args, toExtArgumentType(udf.retType), true);
380  }
static ExtensionFunction.ExtArgumentType toExtArgumentType(TExtArgumentType type)
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ toExtensionFunction() [2/2]

static ExtensionFunction com.mapd.parser.server.CalciteServerHandler.toExtensionFunction ( TUserDefinedTableFunction  udtf)
inlinestaticprivate

Definition at line 382 of file CalciteServerHandler.java.

References run_benchmark_import.args, com.mapd.parser.server.CalciteServerHandler.toExtArgumentType(), and com.mapd.parser.server.ExtensionFunction.ExtArgumentType.Void.

382  {
383  List<ExtensionFunction.ExtArgumentType> args =
384  new ArrayList<ExtensionFunction.ExtArgumentType>();
385  for (TExtArgumentType atype : udtf.sqlArgTypes) {
386  args.add(toExtArgumentType(atype));
387  }
388  return new ExtensionFunction(args, ExtensionFunction.ExtArgumentType.Void, false);
389  }
static ExtensionFunction.ExtArgumentType toExtArgumentType(TExtArgumentType type)
+ Here is the call graph for this function:

◆ updateMetadata()

void com.mapd.parser.server.CalciteServerHandler.updateMetadata ( String  catalog,
String  table 
) throws TException
inline

Definition at line 259 of file CalciteServerHandler.java.

References run_benchmark_import.parser, Experimental.String, and com.mapd.calcite.parser.MapDParser.updateMetaData().

259  {
260  MAPDLOGGER.debug("Received invalidation from server for " + catalog + " : " + table);
261  long timer = System.currentTimeMillis();
262  callCount++;
263  MapDParser parser;
264  try {
265  parser = (MapDParser) parserPool.borrowObject();
266  } catch (Exception ex) {
267  String msg = "Could not get Parse Item from pool: " + ex.getMessage();
268  MAPDLOGGER.error(msg);
269  return;
270  }
271  CURRENT_PARSER.set(parser);
272  try {
273  parser.updateMetaData(catalog, table);
274  } finally {
275  CURRENT_PARSER.set(null);
276  try {
277  // put parser object back in pool for others to use
278  MAPDLOGGER.debug("Returning object to pool");
279  parserPool.returnObject(parser);
280  } catch (Exception ex) {
281  String msg = "Could not return parse object: " + ex.getMessage();
282  MAPDLOGGER.error(msg);
283  }
284  }
285  }
+ Here is the call graph for this function:

Member Data Documentation

◆ callCount

volatile long com.mapd.parser.server.CalciteServerHandler.callCount
private

Definition at line 66 of file CalciteServerHandler.java.

◆ dataDir

String com.mapd.parser.server.CalciteServerHandler.dataDir
private

◆ extSigs

Map<String, ExtensionFunction> com.mapd.parser.server.CalciteServerHandler.extSigs = null
private

Definition at line 78 of file CalciteServerHandler.java.

◆ extSigsJson

final String com.mapd.parser.server.CalciteServerHandler.extSigsJson
private

◆ MAPDLOGGER

final Logger com.mapd.parser.server.CalciteServerHandler.MAPDLOGGER = LoggerFactory.getLogger(CalciteServerHandler.class)
staticpackage

Definition at line 61 of file CalciteServerHandler.java.

◆ mapdPort

final int com.mapd.parser.server.CalciteServerHandler.mapdPort
private

◆ parserPool

final GenericObjectPool com.mapd.parser.server.CalciteServerHandler.parserPool
private

Definition at line 68 of file CalciteServerHandler.java.

◆ server

TServer com.mapd.parser.server.CalciteServerHandler.server
private

Definition at line 62 of file CalciteServerHandler.java.

◆ skT

SockTransportProperties com.mapd.parser.server.CalciteServerHandler.skT
private

Definition at line 77 of file CalciteServerHandler.java.

◆ udfRTSigs

Map<String, ExtensionFunction> com.mapd.parser.server.CalciteServerHandler.udfRTSigs = null
package

Definition at line 75 of file CalciteServerHandler.java.

◆ udfRTSigsJson

String com.mapd.parser.server.CalciteServerHandler.udfRTSigsJson = ""
private

◆ udfSigsJson

final String com.mapd.parser.server.CalciteServerHandler.udfSigsJson
private

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