OmniSciDB
bf83d84833
|
Public Member Functions | |
MapDParser (String dataDir, final Supplier< MapDSqlOperatorTable > mapDSqlOperatorTable, int mapdPort, SockTransportProperties skT) | |
void | clearMemo () |
void | setUser (MapDUser mapdUser) |
Pair< String, SqlIdentifierCapturer > | process (String sql, final MapDParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
String | optimizeRAQuery (String query) throws IOException |
String | processSql (String sql, final MapDParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
String | processSql (final SqlNode sqlNode, final MapDParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
MapDPlanner.CompletionResult | getCompletionHints (String sql, int cursor, List< String > visible_tables) |
Set< String > | resolveSelectIdentifiers (SqlIdentifierCapturer capturer) |
SqlIdentifierCapturer | captureIdentifiers (String sql, boolean legacy_syntax) throws SqlParseException |
SqlIdentifierCapturer | captureIdentifiers (SqlNode node) throws SqlParseException |
int | getCallCount () |
void | updateMetaData (String schema, String table) |
Static Public Attributes | |
static final ThreadLocal < MapDParser > | CURRENT_PARSER = new ThreadLocal<>() |
Protected Member Functions | |
RelDataTypeSystem | createTypeSystem () |
Package Functions | |
RelRoot | queryToRelNode (final String sql, final MapDParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
RelRoot | convertSqlToRelNode (final SqlNode sqlNode, final MapDPlanner mapDPlanner, final MapDParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
Package Attributes | |
SqlNode | sqlNode_ |
Static Package Attributes | |
static final Logger | MAPDLOGGER = LoggerFactory.getLogger(MapDParser.class) |
Private Member Functions | |
MapDPlanner | getPlanner () |
boolean | isCorrelated (SqlNode expression) |
MapDPlanner | getPlanner (final boolean allowSubQueryExpansion, final boolean allowPushdownJoinCondition) |
String | getTableName (SqlNode node) |
SqlSelect | rewriteSimpleUpdateAsSelect (final SqlUpdate update) |
LogicalTableModify | getDummyUpdate (SqlUpdate update) throws SqlParseException, ValidationException, RelConversionException |
RelRoot | rewriteUpdateAsSelect (SqlUpdate update, MapDParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
RelRoot | replaceIsTrue (final RelDataTypeFactory typeFactory, RelRoot root) |
SqlNode | parseSql (String sql, final boolean legacy_syntax, Planner planner) throws SqlParseException |
void | desugar (SqlSelect select_node, RelDataTypeFactory typeFactory) |
SqlNode | expandCase (SqlCase old_case_node, RelDataTypeFactory typeFactory) |
SqlOrderBy | desugar (SqlSelect select_node, SqlOrderBy order_by_node, RelDataTypeFactory typeFactory) |
void | desugarExpression (SqlNode node, RelDataTypeFactory typeFactory) |
SqlNode | expand (final SqlNode node, final java.util.Map< String, SqlNode > id_to_expr, RelDataTypeFactory typeFactory) |
SqlNodeList | expand (final SqlNodeList group_by_list, final java.util.Map< String, SqlNode > id_to_expr, RelDataTypeFactory typeFactory) |
SqlNode | expandVariance (final SqlBasicCall proj_call, RelDataTypeFactory typeFactory) |
SqlNode | expandVariance (final SqlParserPos pos, final SqlNode operand, boolean biased, boolean sqrt, boolean flt, RelDataTypeFactory typeFactory) |
SqlNode | expandCovariance (final SqlBasicCall proj_call, RelDataTypeFactory typeFactory) |
SqlNode | expandCovariance (SqlParserPos pos, final SqlNode operand0, final SqlNode operand1, boolean pop, boolean flt, RelDataTypeFactory typeFactory) |
SqlNode | expandCorrelation (final SqlBasicCall proj_call, RelDataTypeFactory typeFactory) |
Private Attributes | |
final Supplier < MapDSqlOperatorTable > | mapDSqlOperatorTable |
final String | dataDir |
int | callCount = 0 |
final int | mapdPort |
MapDUser | mapdUser |
SockTransportProperties | sock_transport_properties = null |
Static Private Attributes | |
static final EnumSet< SqlKind > | SCALAR |
static final EnumSet< SqlKind > | EXISTS = EnumSet.of(SqlKind.EXISTS) |
static final EnumSet< SqlKind > | DELETE = EnumSet.of(SqlKind.DELETE) |
static final EnumSet< SqlKind > | UPDATE = EnumSet.of(SqlKind.UPDATE) |
static final EnumSet< SqlKind > | IN = EnumSet.of(SqlKind.IN) |
static final EnumSet< SqlKind > | ARRAY_VALUE |
static Map< String, Boolean > | SubqueryCorrMemo = new ConcurrentHashMap<>() |
static final Context | MAPD_CONNECTION_CONTEXT |
Definition at line 138 of file MapDParser.java.
|
inline |
Definition at line 162 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.dataDir, com.mapd.calcite.parser.MapDParser.mapdPort, and com.mapd.calcite.parser.MapDParser.mapDSqlOperatorTable.
Referenced by com.mapd.calcite.parser.MapDParser.isCorrelated().
|
inline |
Definition at line 1391 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.process().
|
inline |
Definition at line 1403 of file MapDParser.java.
|
inline |
Definition at line 172 of file MapDParser.java.
|
inlinepackage |
Definition at line 750 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.processSql().
|
inlineprotected |
Definition at line 1425 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner().
|
inlineprivate |
Definition at line 941 of file MapDParser.java.
|
inlineprivate |
Definition at line 991 of file MapDParser.java.
|
inlineprivate |
Definition at line 1046 of file MapDParser.java.
|
inlineprivate |
Definition at line 1064 of file MapDParser.java.
|
inlineprivate |
Definition at line 1094 of file MapDParser.java.
|
inlineprivate |
Definition at line 945 of file MapDParser.java.
|
inlineprivate |
Definition at line 1344 of file MapDParser.java.
|
inlineprivate |
Definition at line 1252 of file MapDParser.java.
|
inlineprivate |
Definition at line 1285 of file MapDParser.java.
|
inlineprivate |
Definition at line 1113 of file MapDParser.java.
|
inlineprivate |
|
inline |
Definition at line 1414 of file MapDParser.java.
Referenced by com.mapd.parser.server.CalciteParserFactory.validateObject().
|
inline |
Definition at line 430 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.getPlanner().
|
inlineprivate |
Definition at line 565 of file MapDParser.java.
|
inlineprivate |
Definition at line 210 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getCompletionHints(), com.mapd.calcite.parser.MapDParser.optimizeRAQuery(), com.mapd.calcite.parser.MapDParser.process(), and com.mapd.calcite.parser.MapDParser.processSql().
|
inlineprivate |
Definition at line 236 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.createTypeSystem(), com.mapd.calcite.parser.MapDParser.dataDir, com.mapd.calcite.parser.MapDParser.EXISTS, com.mapd.calcite.parser.MapDUser.getDB(), com.mapd.parser.hint.OmniSciHintStrategyTable.HINT_STRATEGY_TABLE, com.mapd.calcite.parser.MapDParser.IN, com.mapd.calcite.parser.MapDParser.isCorrelated(), com.mapd.calcite.parser.MapDParser.MAPD_CONNECTION_CONTEXT, com.mapd.calcite.parser.MapDParser.mapdPort, com.mapd.calcite.parser.MapDParser.mapdUser, com.mapd.calcite.parser.MapDParser.SCALAR, com.mapd.calcite.parser.MapDParser.sock_transport_properties, toString(), and run_benchmark_import.type.
|
inlineprivate |
Definition at line 457 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.rewriteSimpleUpdateAsSelect().
|
inlineprivate |
Definition at line 214 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.dataDir, com.mapd.calcite.parser.MapDParser.MapDParser(), com.mapd.calcite.parser.MapDParser.mapdPort, com.mapd.calcite.parser.MapDParser.mapDSqlOperatorTable, com.mapd.calcite.parser.MapDParser.mapdUser, run_benchmark_import.parser, and com.mapd.calcite.parser.MapDParser.sock_transport_properties.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner(), and com.mapd.calcite.parser.MapDParser.rewriteSimpleUpdateAsSelect().
|
inline |
Definition at line 384 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.dataDir, com.mapd.calcite.parser.MapDParser.getPlanner(), com.mapd.calcite.parser.MapDParser.mapdPort, com.mapd.calcite.parser.MapDParser.mapdUser, com.mapd.calcite.parser.MapDParser.replaceIsTrue(), and com.mapd.calcite.parser.MapDParser.sock_transport_properties.
|
inlineprivate |
Definition at line 896 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.process(), and com.mapd.calcite.parser.MapDParser.processSql().
|
inline |
Definition at line 373 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.captureIdentifiers(), com.mapd.calcite.parser.MapDParser.getPlanner(), com.mapd.calcite.parser.MapDParser.parseSql(), com.mapd.calcite.parser.MapDParser.processSql(), and run_benchmark_import.res.
|
inline |
Definition at line 393 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.callCount, com.mapd.calcite.parser.MapDParser.getPlanner(), and com.mapd.calcite.parser.MapDParser.parseSql().
Referenced by com.mapd.calcite.parser.MapDParser.process().
|
inline |
Definition at line 403 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.callCount, com.mapd.calcite.parser.MapDParser.convertSqlToRelNode(), com.mapd.calcite.parser.MapDParser.getPlanner(), and run_benchmark_import.res.
|
inlinepackage |
Definition at line 743 of file MapDParser.java.
|
inlineprivate |
Definition at line 848 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.optimizeRAQuery().
|
inline |
Definition at line 435 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.dataDir, com.mapd.calcite.parser.MapDView.getAccessedObjects(), com.mapd.calcite.parser.MapDSchema.getTable(), com.mapd.calcite.parser.MapDParser.mapdPort, com.mapd.calcite.parser.MapDParser.mapdUser, setup.name, org.apache.calcite.prepare.SqlIdentifierCapturer.selects, and com.mapd.calcite.parser.MapDParser.sock_transport_properties.
|
inlineprivate |
Definition at line 468 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.getTableName(), com.mapd.calcite.parser.MapDParser.isCorrelated(), and join().
|
inlineprivate |
Definition at line 578 of file MapDParser.java.
References com.mapd.calcite.parser.MapDSqlOperatorTable.ARRAY_VALUE_CONSTRUCTOR, setup.name, and Void.
|
inline |
Definition at line 369 of file MapDParser.java.
References com.mapd.calcite.parser.MapDParser.mapdUser.
|
inline |
Definition at line 1418 of file MapDParser.java.
|
staticprivate |
Definition at line 146 of file MapDParser.java.
|
private |
Definition at line 154 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.processSql().
|
static |
Definition at line 139 of file MapDParser.java.
|
private |
Definition at line 152 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner(), com.mapd.calcite.parser.MapDParser.isCorrelated(), com.mapd.calcite.parser.MapDParser.MapDParser(), com.mapd.calcite.parser.MapDParser.optimizeRAQuery(), and com.mapd.calcite.parser.MapDParser.resolveSelectIdentifiers().
|
staticprivate |
Definition at line 143 of file MapDParser.java.
|
staticprivate |
Definition at line 142 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner().
|
staticprivate |
Definition at line 145 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner().
|
staticprivate |
Definition at line 176 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner().
|
staticpackage |
Definition at line 149 of file MapDParser.java.
|
private |
Definition at line 155 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner(), com.mapd.calcite.parser.MapDParser.isCorrelated(), com.mapd.calcite.parser.MapDParser.MapDParser(), com.mapd.calcite.parser.MapDParser.optimizeRAQuery(), and com.mapd.calcite.parser.MapDParser.resolveSelectIdentifiers().
|
private |
Definition at line 151 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.isCorrelated(), and com.mapd.calcite.parser.MapDParser.MapDParser().
|
private |
Definition at line 156 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner(), com.mapd.calcite.parser.MapDParser.isCorrelated(), com.mapd.calcite.parser.MapDParser.optimizeRAQuery(), com.mapd.calcite.parser.MapDParser.resolveSelectIdentifiers(), and com.mapd.calcite.parser.MapDParser.setUser().
|
staticprivate |
Definition at line 140 of file MapDParser.java.
Referenced by com.mapd.calcite.parser.MapDParser.getPlanner().
|
private |
|
package |
Definition at line 157 of file MapDParser.java.
|
staticprivate |
Definition at line 160 of file MapDParser.java.
|
staticprivate |
Definition at line 144 of file MapDParser.java.