OmniSciDB
bf83d84833
|
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, ExtensionFunction > | udfRTSigs = 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, ExtensionFunction > | extSigs = null |
String | dataDir |
Definition at line 62 of file CalciteServerHandler.java.
|
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.
|
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.
|
inline |
Definition at line 259 of file CalciteServerHandler.java.
|
inline |
Definition at line 269 of file CalciteServerHandler.java.
|
inline |
Definition at line 264 of file CalciteServerHandler.java.
|
inlinestaticprivate |
Definition at line 503 of file CalciteServerHandler.java.
References TABLE.
Referenced by com.mapd.parser.server.CalciteServerHandler.getCompletionHints().
|
inline |
Definition at line 127 of file CalciteServerHandler.java.
|
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.
|
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.
|
inlinepackage |
Definition at line 273 of file CalciteServerHandler.java.
References com.mapd.parser.server.CalciteServerHandler.server.
|
inline |
Definition at line 252 of file CalciteServerHandler.java.
|
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().
|
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().
|
inlinestaticprivate |
Definition at line 404 of file CalciteServerHandler.java.
References run_benchmark_import.args, and com.mapd.parser.server.CalciteServerHandler.toExtArgumentType().
|
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.
|
private |
Definition at line 72 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.CalciteServerHandler().
|
private |
Definition at line 68 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.getCompletionHints(), com.mapd.parser.server.CalciteServerHandler.process(), and com.mapd.parser.server.CalciteServerHandler.updateMetadata().
|
private |
Definition at line 83 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.CalciteServerHandler().
|
private |
Definition at line 82 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.CalciteServerHandler(), and com.mapd.parser.server.CalciteServerHandler.setRuntimeExtensionFunctions().
|
private |
Definition at line 74 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.CalciteServerHandler().
|
staticpackage |
Definition at line 63 of file CalciteServerHandler.java.
|
private |
Definition at line 66 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.CalciteServerHandler(), com.mapd.parser.server.CalciteServerHandler.getCompletionHints(), and com.mapd.parser.server.CalciteServerHandler.process().
|
private |
Definition at line 70 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.getCompletionHints(), com.mapd.parser.server.CalciteServerHandler.process(), and com.mapd.parser.server.CalciteServerHandler.updateMetadata().
|
private |
Definition at line 64 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.setServer().
|
private |
Definition at line 81 of file CalciteServerHandler.java.
|
package |
Definition at line 79 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.setRuntimeExtensionFunctions().
|
private |
Definition at line 78 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.setRuntimeExtensionFunctions().
|
private |
Definition at line 76 of file CalciteServerHandler.java.
Referenced by com.mapd.parser.server.CalciteServerHandler.CalciteServerHandler().