OmniSciDB
c1a53651b2
|
Classes | |
class | ExpressionListedAsChildOROperatorChecker |
class | ExpressionListedInSelectClauseChecker |
class | FindSqlOperator |
class | JoinOperatorChecker |
Public Member Functions | |
HeavyDBParser (String dataDir, final Supplier< HeavyDBSqlOperatorTable > dbSqlOperatorTable, int dbPort, SockTransportProperties skT) | |
void | clearMemo () |
void | setUser (HeavyDBUser dbUser) |
Pair< String, SqlIdentifierCapturer > | process (String sql, final HeavyDBParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
String | buildRATreeAndPerformQueryOptimization (String query, final HeavyDBParserOptions parserOptions) throws IOException |
String | processSql (String sql, final HeavyDBParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
String | processSql (final SqlNode sqlNode, final HeavyDBParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
HeavyDBPlanner.CompletionResult | getCompletionHints (String sql, int cursor, List< String > visible_tables) |
HashSet< ImmutableList< 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) |
void | tableAliasFinder (SqlNode sqlNode, Map< String, String > tableAliasMap) |
Static Public Attributes | |
static final ThreadLocal < HeavyDBParser > | CURRENT_PARSER = new ThreadLocal<>() |
Protected Member Functions | |
RelDataTypeSystem | createTypeSystem () |
Package Functions | |
RelRoot | queryToRelNode (final String sql, final HeavyDBParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
RelRoot | convertSqlToRelNode (final SqlNode sqlNode, final HeavyDBPlanner HeavyDBPlanner, final HeavyDBParserOptions parserOptions) throws SqlParseException, ValidationException, RelConversionException |
Static Package Attributes | |
static final Logger | HEAVYDBLOGGER = LoggerFactory.getLogger(HeavyDBParser.class) |
Private Member Functions | |
HeavyDBPlanner | getPlanner () |
boolean | isCorrelated (SqlNode expression) |
boolean | isHashJoinableType (TColumnType type) |
boolean | isColumnHashJoinable (List< String > joinColumnIdentifier, MetaConnect mc) |
HeavyDBPlanner | getPlanner (final boolean allowSubQueryExpansion, final boolean isWatchdogEnabled, final boolean isDistributedMode) |
String | getTableName (SqlNode node) |
SqlSelect | rewriteSimpleUpdateAsSelect (final SqlUpdate update) |
LogicalTableModify | getDummyUpdate (SqlUpdate update) throws SqlParseException, ValidationException, RelConversionException |
RelRoot | rewriteUpdateAsSelect (SqlUpdate update, HeavyDBParserOptions 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 | expandStringFunctions (final SqlBasicCall proj_call, 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) |
Set< ImmutableList< String > > | addDbContextIfMissing (Set< ImmutableList< String >> names) |
Private Attributes | |
final Supplier < HeavyDBSqlOperatorTable > | dbSqlOperatorTable |
final String | dataDir |
int | callCount = 0 |
final int | dbPort |
HeavyDBUser | dbUser |
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 final EnumSet< SqlKind > | OTHER_FUNCTION |
static Map< String, Boolean > | SubqueryCorrMemo = new ConcurrentHashMap<>() |
static final Context | DB_CONNECTION_CONTEXT |
Definition at line 95 of file HeavyDBParser.java.
|
inline |
Definition at line 120 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.dataDir, com.mapd.calcite.parser.HeavyDBParser.dbPort, and com.mapd.calcite.parser.HeavyDBParser.dbSqlOperatorTable.
Referenced by com.mapd.calcite.parser.HeavyDBParser.isCorrelated().
|
inlineprivate |
Definition at line 1743 of file HeavyDBParser.java.
References setup.name, and run_benchmark_import.result.
|
inline |
Definition at line 451 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.dataDir, com.mapd.calcite.parser.HeavyDBParser.dbPort, com.mapd.calcite.parser.HeavyDBParser.dbUser, com.mapd.calcite.parser.HeavyDBUser.getDB(), com.mapd.calcite.parser.HeavyDBParser.getPlanner(), com.mapd.calcite.parser.HeavyDBParser.replaceIsTrue(), and com.mapd.calcite.parser.HeavyDBParser.sock_transport_properties.
|
inline |
Definition at line 1716 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.process().
|
inline |
Definition at line 1728 of file HeavyDBParser.java.
References org.apache.calcite.prepare.SqlIdentifierCapturer.deletes, org.apache.calcite.prepare.SqlIdentifierCapturer.inserts, org.apache.calcite.prepare.SqlIdentifierCapturer.selects, and org.apache.calcite.prepare.SqlIdentifierCapturer.updates.
|
inline |
Definition at line 130 of file HeavyDBParser.java.
|
inlinepackage |
Definition at line 874 of file HeavyDBParser.java.
References anonymous_namespace{Utm.h}.f, and setup.root.
Referenced by com.mapd.calcite.parser.HeavyDBParser.processSql().
|
inlineprotected |
Definition at line 1770 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner().
|
inlineprivate |
Definition at line 1048 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1098 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1153 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1171 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1205 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1052 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1669 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1577 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1610 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1224 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 1438 of file HeavyDBParser.java.
|
inlineprivate |
|
inline |
Definition at line 1759 of file HeavyDBParser.java.
Referenced by com.mapd.parser.server.CalciteParserFactory.validateObject().
|
inline |
Definition at line 504 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.getPlanner().
|
inlineprivate |
Definition at line 643 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 168 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.buildRATreeAndPerformQueryOptimization(), com.mapd.calcite.parser.HeavyDBParser.getCompletionHints(), com.mapd.calcite.parser.HeavyDBParser.process(), and com.mapd.calcite.parser.HeavyDBParser.processSql().
|
inlineprivate |
Definition at line 230 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.JoinOperatorChecker.containsExpression(), com.mapd.calcite.parser.HeavyDBParser.createTypeSystem(), com.mapd.calcite.parser.HeavyDBParser.dataDir, com.mapd.calcite.parser.HeavyDBParser.DB_CONNECTION_CONTEXT, com.mapd.calcite.parser.HeavyDBParser.dbPort, com.mapd.calcite.parser.HeavyDBParser.dbUser, com.mapd.calcite.parser.HeavyDBParser.EXISTS, com.mapd.metadata.MetaConnect.getDatabases(), com.mapd.calcite.parser.HeavyDBUser.getDB(), com.mapd.calcite.parser.HeavyDBUser.getUser(), com.mapd.parser.hint.HeavyDBHintStrategyTable.HINT_STRATEGY_TABLE, com.mapd.calcite.parser.HeavyDBParser.IN, com.mapd.calcite.parser.HeavyDBParser.isColumnHashJoinable(), com.mapd.calcite.parser.HeavyDBParser.isCorrelated(), setup.root, com.mapd.calcite.parser.HeavyDBParser.SCALAR, com.mapd.calcite.parser.HeavyDBParser.sock_transport_properties, and com.mapd.calcite.parser.HeavyDBParser.tableAliasFinder().
|
inlineprivate |
Definition at line 532 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.rewriteSimpleUpdateAsSelect().
|
inlineprivate |
Definition at line 211 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.isHashJoinableType().
Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner().
|
inlineprivate |
Definition at line 172 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.dataDir, com.mapd.calcite.parser.HeavyDBParser.dbPort, com.mapd.calcite.parser.HeavyDBParser.dbSqlOperatorTable, com.mapd.calcite.parser.HeavyDBParser.dbUser, com.mapd.calcite.parser.HeavyDBParser.HeavyDBParser(), run_benchmark_import.parser, and com.mapd.calcite.parser.HeavyDBParser.sock_transport_properties.
Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner(), and com.mapd.calcite.parser.HeavyDBParser.rewriteSimpleUpdateAsSelect().
|
inlineprivate |
Definition at line 194 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.isColumnHashJoinable().
|
inlineprivate |
Definition at line 1003 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.process(), and com.mapd.calcite.parser.HeavyDBParser.processSql().
|
inline |
Definition at line 440 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.captureIdentifiers(), com.mapd.calcite.parser.HeavyDBParser.getPlanner(), com.mapd.calcite.parser.HeavyDBParser.parseSql(), com.mapd.calcite.parser.HeavyDBParser.processSql(), and run_benchmark_import.res.
|
inline |
Definition at line 464 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.callCount, com.mapd.calcite.parser.HeavyDBParser.getPlanner(), and com.mapd.calcite.parser.HeavyDBParser.parseSql().
Referenced by com.mapd.calcite.parser.HeavyDBParser.process().
|
inline |
Definition at line 475 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.callCount, com.mapd.calcite.parser.HeavyDBParser.convertSqlToRelNode(), com.mapd.calcite.parser.HeavyDBParser.getPlanner(), and run_benchmark_import.res.
|
inlinepackage |
Definition at line 866 of file HeavyDBParser.java.
|
inlineprivate |
Definition at line 955 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.buildRATreeAndPerformQueryOptimization().
|
inline |
Definition at line 509 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.dataDir, com.mapd.calcite.parser.HeavyDBParser.dbPort, com.mapd.calcite.parser.HeavyDBParser.dbUser, com.mapd.calcite.parser.HeavyDBView.getAccessedObjects(), com.mapd.calcite.parser.HeavyDBSchema.getTable(), org.apache.calcite.prepare.SqlIdentifierCapturer.selects, and com.mapd.calcite.parser.HeavyDBParser.sock_transport_properties.
|
inlineprivate |
Definition at line 543 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.getTableName(), com.mapd.calcite.parser.HeavyDBParser.isCorrelated(), and join().
|
inlineprivate |
Definition at line 656 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBSqlOperatorTable.ARRAY_VALUE_CONSTRUCTOR, setup.name, and Void.
|
inline |
Definition at line 436 of file HeavyDBParser.java.
References com.mapd.calcite.parser.HeavyDBParser.dbUser.
|
inline |
Definition at line 1909 of file HeavyDBParser.java.
References toString(), and Void.
Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner().
|
inline |
Definition at line 1763 of file HeavyDBParser.java.
|
staticprivate |
Definition at line 103 of file HeavyDBParser.java.
|
private |
Definition at line 113 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.processSql().
|
static |
Definition at line 96 of file HeavyDBParser.java.
|
private |
Definition at line 111 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.buildRATreeAndPerformQueryOptimization(), com.mapd.calcite.parser.HeavyDBParser.getPlanner(), com.mapd.calcite.parser.HeavyDBParser.HeavyDBParser(), com.mapd.calcite.parser.HeavyDBParser.isCorrelated(), and com.mapd.calcite.parser.HeavyDBParser.resolveSelectIdentifiers().
|
staticprivate |
Definition at line 134 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner().
|
private |
Definition at line 114 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.buildRATreeAndPerformQueryOptimization(), com.mapd.calcite.parser.HeavyDBParser.getPlanner(), com.mapd.calcite.parser.HeavyDBParser.HeavyDBParser(), com.mapd.calcite.parser.HeavyDBParser.isCorrelated(), and com.mapd.calcite.parser.HeavyDBParser.resolveSelectIdentifiers().
|
private |
Definition at line 110 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.HeavyDBParser(), and com.mapd.calcite.parser.HeavyDBParser.isCorrelated().
|
private |
Definition at line 115 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.buildRATreeAndPerformQueryOptimization(), com.mapd.calcite.parser.HeavyDBParser.getPlanner(), com.mapd.calcite.parser.HeavyDBParser.isCorrelated(), com.mapd.calcite.parser.HeavyDBParser.resolveSelectIdentifiers(), and com.mapd.calcite.parser.HeavyDBParser.setUser().
|
staticprivate |
Definition at line 100 of file HeavyDBParser.java.
|
staticprivate |
Definition at line 99 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner().
|
staticpackage |
Definition at line 108 of file HeavyDBParser.java.
|
staticprivate |
Definition at line 102 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner().
|
staticprivate |
Definition at line 105 of file HeavyDBParser.java.
|
staticprivate |
Definition at line 97 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner().
|
private |
Definition at line 116 of file HeavyDBParser.java.
Referenced by com.mapd.calcite.parser.HeavyDBParser.buildRATreeAndPerformQueryOptimization(), com.mapd.calcite.parser.HeavyDBParser.getPlanner(), com.mapd.calcite.parser.HeavyDBParser.isCorrelated(), and com.mapd.calcite.parser.HeavyDBParser.resolveSelectIdentifiers().
|
staticprivate |
Definition at line 118 of file HeavyDBParser.java.
|
staticprivate |
Definition at line 101 of file HeavyDBParser.java.