OmniSciDB  bf83d84833
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
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

 CalciteServerHandler (int mapdPort, String dataDir, String extensionFunctionsAstFile, SockTransportProperties skT, String udfAstFile)
 
void ping () throws TException
 
TPlanResult process (String user, String session, String catalog, String queryText, 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

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 CalciteParserFactory calciteParserFactory
 
final String extSigsJson
 
final String udfSigsJson
 
String udfRTSigsJson = ""
 
SockTransportProperties skT
 
Map< String, ExtensionFunctionextSigs = null
 
String dataDir
 

Detailed Description

Author
michael

Definition at line 62 of file CalciteServerHandler.java.

Constructor & Destructor Documentation

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

Definition at line 87 of file CalciteServerHandler.java.

References com.mapd.parser.server.CalciteServerHandler.calciteParserFactory, com.mapd.parser.server.CalciteServerHandler.dataDir, com.mapd.parser.server.CalciteServerHandler.extSigs, com.mapd.parser.server.CalciteServerHandler.extSigsJson, com.mapd.parser.server.CalciteServerHandler.mapdPort, and com.mapd.parser.server.CalciteServerHandler.udfSigsJson.

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

Member Function Documentation

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 307 of file CalciteServerHandler.java.

References com.mapd.parser.server.CalciteServerHandler.callCount, com.mapd.parser.server.CalciteServerHandler.hintTypeToThrift(), com.mapd.parser.server.CalciteServerHandler.mapdPort, run_benchmark_import.parser, com.mapd.parser.server.CalciteServerHandler.parserPool, and run_benchmark_import.result.

312  {
313  callCount++;
314  MapDParser parser;
315  try {
316  parser = (MapDParser) parserPool.borrowObject();
317  } catch (Exception ex) {
318  String msg = "Could not get Parse Item from pool: " + ex.getMessage();
319  MAPDLOGGER.error(msg, ex);
320  throw new TException(msg);
321  }
322  MapDUser mapDUser = new MapDUser(user, session, catalog, mapdPort);
323  MAPDLOGGER.debug("getCompletionHints was called User: " + user
324  + " Catalog: " + catalog + " sql: " + sql);
325  parser.setUser(mapDUser);
326  CURRENT_PARSER.set(parser);
327 
328  MapDPlanner.CompletionResult completion_result;
329  try {
330  completion_result = parser.getCompletionHints(sql, cursor, visible_tables);
331  } catch (Exception ex) {
332  String msg = "Could not retrieve completion hints: " + ex.getMessage();
333  MAPDLOGGER.error(msg, ex);
334  return new ArrayList<>();
335  } finally {
336  CURRENT_PARSER.set(null);
337  try {
338  // put parser object back in pool for others to use
339  parserPool.returnObject(parser);
340  } catch (Exception ex) {
341  String msg = "Could not return parse object: " + ex.getMessage();
342  MAPDLOGGER.error(msg, ex);
343  throw new InvalidParseRequest(-4, msg);
344  }
345  }
346  List<TCompletionHint> result = new ArrayList<>();
347  for (final SqlMoniker hint : completion_result.hints) {
348  result.add(new TCompletionHint(hintTypeToThrift(hint.getType()),
349  hint.getFullyQualifiedNames(),
350  completion_result.replaced));
351  }
352  return result;
353  }
static TCompletionHintType hintTypeToThrift(final SqlMonikerType type)

+ Here is the call graph for this function:

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

Definition at line 259 of file CalciteServerHandler.java.

259  {
260  return this.extSigsJson;
261  }
String com.mapd.parser.server.CalciteServerHandler.getRuntimeExtensionFunctionWhitelist ( )
inline

Definition at line 269 of file CalciteServerHandler.java.

269  {
270  return this.udfRTSigsJson;
271  }
String com.mapd.parser.server.CalciteServerHandler.getUserDefinedFunctionWhitelist ( )
inline

Definition at line 264 of file CalciteServerHandler.java.

264  {
265  return this.udfSigsJson;
266  }
static TCompletionHintType com.mapd.parser.server.CalciteServerHandler.hintTypeToThrift ( final SqlMonikerType  type)
inlinestaticprivate

Definition at line 503 of file CalciteServerHandler.java.

References TABLE.

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

503  {
504  switch (type) {
505  case COLUMN:
506  return TCompletionHintType.COLUMN;
507  case TABLE:
508  return TCompletionHintType.TABLE;
509  case VIEW:
510  return TCompletionHintType.VIEW;
511  case SCHEMA:
512  return TCompletionHintType.SCHEMA;
513  case CATALOG:
514  return TCompletionHintType.CATALOG;
515  case REPOSITORY:
516  return TCompletionHintType.REPOSITORY;
517  case FUNCTION:
518  return TCompletionHintType.FUNCTION;
519  case KEYWORD:
520  return TCompletionHintType.KEYWORD;
521  default:
522  return null;
523  }
524  }

+ Here is the caller graph for this function:

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

Definition at line 127 of file CalciteServerHandler.java.

127  {
128  MAPDLOGGER.debug("Ping hit");
129  }
TPlanResult com.mapd.parser.server.CalciteServerHandler.process ( String  user,
String  session,
String  catalog,
String  queryText,
java.util.List< TFilterPushDownInfo >  thriftFilterPushDownInfo,
boolean  legacySyntax,
boolean  isExplain,
boolean  isViewOptimize 
) throws InvalidParseRequest, TException
inline

Definition at line 132 of file CalciteServerHandler.java.

References com.mapd.parser.server.CalciteServerHandler.callCount, com.mapd.parser.server.CalciteServerHandler.mapdPort, run_benchmark_import.parser, com.mapd.parser.server.CalciteServerHandler.parserPool, run_benchmark_import.res, and run_benchmark_import.result.

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

Definition at line 356 of file CalciteServerHandler.java.

References com.mapd.parser.server.CalciteServerHandler.extSigs, setup.name, com.mapd.parser.server.CalciteServerHandler.toExtensionFunction(), com.mapd.parser.server.CalciteServerHandler.udfRTSigs, and com.mapd.parser.server.CalciteServerHandler.udfRTSigsJson.

357  {
358  // Clean up previously defined Runtime UDFs
359  if (udfRTSigs != null) {
360  for (String name : udfRTSigs.keySet()) extSigs.remove(name);
361  udfRTSigsJson = "";
362  udfRTSigs.clear();
363  } else {
364  udfRTSigs = new HashMap<String, ExtensionFunction>();
365  }
366 
367  for (TUserDefinedFunction udf : udfs) {
368  udfRTSigs.put(udf.name, toExtensionFunction(udf));
369  }
370 
371  for (TUserDefinedTableFunction udtf : udtfs) {
372  udfRTSigs.put(udtf.name, toExtensionFunction(udtf));
373  }
374 
375  // Avoid overwritting compiled and Loadtime UDFs:
376  for (String name : udfRTSigs.keySet()) {
377  if (extSigs.containsKey(name)) {
378  MAPDLOGGER.error("Extension function `" + name
379  + "` exists. Skipping runtime extenension function with the same name.");
380  udfRTSigs.remove(name);
381  }
382  }
383 
384  // udfRTSigsJson will contain only the signatures of UDFs:
385  udfRTSigsJson = ExtensionFunctionSignatureParser.signaturesToJson(udfRTSigs);
386  // Expose RT UDFs to Calcite server:
387  extSigs.putAll(udfRTSigs);
388 
389  calciteParserFactory.updateOperatorTable();
390  }
Map< String, ExtensionFunction > udfRTSigs
static ExtensionFunction toExtensionFunction(TUserDefinedFunction udf)
string name
Definition: setup.py:35

+ Here is the call graph for this function:

void com.mapd.parser.server.CalciteServerHandler.setServer ( TServer  s)
inlinepackage
void com.mapd.parser.server.CalciteServerHandler.shutdown ( ) throws TException
inline

Definition at line 252 of file CalciteServerHandler.java.

252  {
253  // received request to shutdown
254  MAPDLOGGER.debug("Shutdown calcite java server");
255  server.stop();
256  }
static ExtensionFunction.ExtArgumentType com.mapd.parser.server.CalciteServerHandler.toExtArgumentType ( TExtArgumentType  type)
inlinestaticprivate

Definition at line 418 of file CalciteServerHandler.java.

References ArrayBool, ArrayDouble, ArrayFloat, ArrayInt16, ArrayInt32, ArrayInt64, ArrayInt8, Bool, ColumnBool, ColumnDouble, ColumnFloat, ColumnInt16, ColumnInt32, ColumnInt64, ColumnInt8, Cursor, Double, Int16, Int32, Int64, Int8, PBool, PDouble, PFloat, PInt16, PInt32, PInt64, PInt8, TextEncodingDict16, TextEncodingDict32, TextEncodingDict8, TextEncodingNone, run_benchmark_import.type, and Void.

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

419  {
420  switch (type) {
421  case Int8:
422  return ExtensionFunction.ExtArgumentType.Int8;
423  case Int16:
424  return ExtensionFunction.ExtArgumentType.Int16;
425  case Int32:
426  return ExtensionFunction.ExtArgumentType.Int32;
427  case Int64:
428  return ExtensionFunction.ExtArgumentType.Int64;
429  case Float:
430  return ExtensionFunction.ExtArgumentType.Float;
431  case Double:
433  case Void:
434  return ExtensionFunction.ExtArgumentType.Void;
435  case PInt8:
436  return ExtensionFunction.ExtArgumentType.PInt8;
437  case PInt16:
438  return ExtensionFunction.ExtArgumentType.PInt16;
439  case PInt32:
440  return ExtensionFunction.ExtArgumentType.PInt32;
441  case PInt64:
442  return ExtensionFunction.ExtArgumentType.PInt64;
443  case PFloat:
444  return ExtensionFunction.ExtArgumentType.PFloat;
445  case PDouble:
446  return ExtensionFunction.ExtArgumentType.PDouble;
447  case PBool:
448  return ExtensionFunction.ExtArgumentType.PBool;
449  case Bool:
450  return ExtensionFunction.ExtArgumentType.Bool;
451  case ArrayInt8:
452  return ExtensionFunction.ExtArgumentType.ArrayInt8;
453  case ArrayInt16:
454  return ExtensionFunction.ExtArgumentType.ArrayInt16;
455  case ArrayInt32:
456  return ExtensionFunction.ExtArgumentType.ArrayInt32;
457  case ArrayInt64:
458  return ExtensionFunction.ExtArgumentType.ArrayInt64;
459  case ArrayFloat:
460  return ExtensionFunction.ExtArgumentType.ArrayFloat;
461  case ArrayDouble:
462  return ExtensionFunction.ExtArgumentType.ArrayDouble;
463  case ArrayBool:
464  return ExtensionFunction.ExtArgumentType.ArrayBool;
465  case ColumnInt8:
466  return ExtensionFunction.ExtArgumentType.ColumnInt8;
467  case ColumnInt16:
468  return ExtensionFunction.ExtArgumentType.ColumnInt16;
469  case ColumnInt32:
470  return ExtensionFunction.ExtArgumentType.ColumnInt32;
471  case ColumnInt64:
472  return ExtensionFunction.ExtArgumentType.ColumnInt64;
473  case ColumnFloat:
474  return ExtensionFunction.ExtArgumentType.ColumnFloat;
475  case ColumnDouble:
476  return ExtensionFunction.ExtArgumentType.ColumnDouble;
477  case ColumnBool:
478  return ExtensionFunction.ExtArgumentType.ColumnBool;
479  case GeoPoint:
480  return ExtensionFunction.ExtArgumentType.GeoPoint;
481  case GeoLineString:
482  return ExtensionFunction.ExtArgumentType.GeoLineString;
483  case Cursor:
484  return ExtensionFunction.ExtArgumentType.Cursor;
485  case GeoPolygon:
486  return ExtensionFunction.ExtArgumentType.GeoPolygon;
487  case GeoMultiPolygon:
488  return ExtensionFunction.ExtArgumentType.GeoMultiPolygon;
489  case TextEncodingNone:
490  return ExtensionFunction.ExtArgumentType.TextEncodingNone;
491  case TextEncodingDict8:
492  return ExtensionFunction.ExtArgumentType.TextEncodingDict8;
493  case TextEncodingDict16:
494  return ExtensionFunction.ExtArgumentType.TextEncodingDict16;
495  case TextEncodingDict32:
496  return ExtensionFunction.ExtArgumentType.TextEncodingDict32;
497  default:
498  MAPDLOGGER.error("toExtArgumentType: unknown type " + type);
499  return null;
500  }
501  }

+ Here is the caller graph for this function:

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

Definition at line 392 of file CalciteServerHandler.java.

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

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

392  {
393  List<ExtensionFunction.ExtArgumentType> args =
394  new ArrayList<ExtensionFunction.ExtArgumentType>();
395  for (TExtArgumentType atype : udf.argTypes) {
396  final ExtensionFunction.ExtArgumentType arg_type = toExtArgumentType(atype);
397  if (arg_type != ExtensionFunction.ExtArgumentType.Void) {
398  args.add(arg_type);
399  }
400  }
401  return new ExtensionFunction(args, toExtArgumentType(udf.retType));
402  }
static ExtensionFunction.ExtArgumentType toExtArgumentType(TExtArgumentType type)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

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

Definition at line 404 of file CalciteServerHandler.java.

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

404  {
405  List<ExtensionFunction.ExtArgumentType> args =
406  new ArrayList<ExtensionFunction.ExtArgumentType>();
407  for (TExtArgumentType atype : udtf.sqlArgTypes) {
408  args.add(toExtArgumentType(atype));
409  }
410  List<ExtensionFunction.ExtArgumentType> outs =
411  new ArrayList<ExtensionFunction.ExtArgumentType>();
412  for (TExtArgumentType otype : udtf.outputArgTypes) {
413  outs.add(toExtArgumentType(otype));
414  }
415  return new ExtensionFunction(args, outs);
416  }
static ExtensionFunction.ExtArgumentType toExtArgumentType(TExtArgumentType type)

+ Here is the call graph for this function:

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

Definition at line 278 of file CalciteServerHandler.java.

References com.mapd.parser.server.CalciteServerHandler.callCount, run_benchmark_import.parser, and com.mapd.parser.server.CalciteServerHandler.parserPool.

278  {
279  MAPDLOGGER.debug("Received invalidation from server for " + catalog + " : " + table);
280  long timer = System.currentTimeMillis();
281  callCount++;
282  MapDParser parser;
283  try {
284  parser = (MapDParser) parserPool.borrowObject();
285  } catch (Exception ex) {
286  String msg = "Could not get Parse Item from pool: " + ex.getMessage();
287  MAPDLOGGER.error(msg, ex);
288  return;
289  }
290  CURRENT_PARSER.set(parser);
291  try {
292  parser.updateMetaData(catalog, table);
293  } finally {
294  CURRENT_PARSER.set(null);
295  try {
296  // put parser object back in pool for others to use
297  MAPDLOGGER.debug("Returning object to pool");
298  parserPool.returnObject(parser);
299  } catch (Exception ex) {
300  String msg = "Could not return parse object: " + ex.getMessage();
301  MAPDLOGGER.error(msg, ex);
302  }
303  }
304  }

Member Data Documentation

final CalciteParserFactory com.mapd.parser.server.CalciteServerHandler.calciteParserFactory
private
String com.mapd.parser.server.CalciteServerHandler.dataDir
private
Map<String, ExtensionFunction> com.mapd.parser.server.CalciteServerHandler.extSigs = null
private
final String com.mapd.parser.server.CalciteServerHandler.extSigsJson
private
final Logger com.mapd.parser.server.CalciteServerHandler.MAPDLOGGER = LoggerFactory.getLogger(CalciteServerHandler.class)
staticpackage

Definition at line 63 of file CalciteServerHandler.java.

final GenericObjectPool com.mapd.parser.server.CalciteServerHandler.parserPool
private
TServer com.mapd.parser.server.CalciteServerHandler.server
private
SockTransportProperties com.mapd.parser.server.CalciteServerHandler.skT
private

Definition at line 81 of file CalciteServerHandler.java.

Map<String, ExtensionFunction> com.mapd.parser.server.CalciteServerHandler.udfRTSigs = null
package
String com.mapd.parser.server.CalciteServerHandler.udfRTSigsJson = ""
private
final String com.mapd.parser.server.CalciteServerHandler.udfSigsJson
private

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