Class com::mapd::calcite::parser::MapDParser

class MapDParser

Author

michael

Public Functions

com.mapd.calcite.parser.MapDParser.MapDParser(String dataDir, final Supplier< MapDSqlOperatorTable > mapDSqlOperatorTable, int mapdPort, SockTransportProperties skT)

void com.mapd.calcite.parser.MapDParser.clearMemo()

void com.mapd.calcite.parser.MapDParser.setUser(MapDUser mapdUser)

Pair<String, SqlIdentifierCapturer> com.mapd.calcite.parser.MapDParser.process(String sql, final MapDParserOptions parserOptions)

String com.mapd.calcite.parser.MapDParser.optimizeRAQuery(String query, final MapDParserOptions parserOptions)

String com.mapd.calcite.parser.MapDParser.processSql(String sql, final MapDParserOptions parserOptions)

String com.mapd.calcite.parser.MapDParser.processSql(final SqlNode sqlNode, final MapDParserOptions parserOptions)

MapDPlanner.CompletionResult com.mapd.calcite.parser.MapDParser.getCompletionHints(String sql, int cursor, List< String > visible_tables)

HashSet<ImmutableList<String> > com.mapd.calcite.parser.MapDParser.resolveSelectIdentifiers(SqlIdentifierCapturer capturer)

SqlIdentifierCapturer com.mapd.calcite.parser.MapDParser.captureIdentifiers(String sql, boolean legacy_syntax)

SqlIdentifierCapturer com.mapd.calcite.parser.MapDParser.captureIdentifiers(SqlNode node)

int com.mapd.calcite.parser.MapDParser.getCallCount()

void com.mapd.calcite.parser.MapDParser.updateMetaData(String schema, String table)

Public Static Attributes

final ThreadLocal<MapDParser> com.mapd.calcite.parser.MapDParser.CURRENT_PARSER = new ThreadLocal<>()

Protected Functions

RelDataTypeSystem com.mapd.calcite.parser.MapDParser.createTypeSystem()

Private Functions

MapDPlanner com.mapd.calcite.parser.MapDParser.getPlanner()

boolean com.mapd.calcite.parser.MapDParser.isCorrelated(SqlNode expression)

MapDPlanner com.mapd.calcite.parser.MapDParser.getPlanner(final boolean allowSubQueryExpansion, final boolean isWatchdogEnabled)

String com.mapd.calcite.parser.MapDParser.getTableName(SqlNode node)

SqlSelect com.mapd.calcite.parser.MapDParser.rewriteSimpleUpdateAsSelect(final SqlUpdate update)

LogicalTableModify com.mapd.calcite.parser.MapDParser.getDummyUpdate(SqlUpdate update)

RelRoot com.mapd.calcite.parser.MapDParser.rewriteUpdateAsSelect(SqlUpdate update, MapDParserOptions parserOptions)

RelRoot com.mapd.calcite.parser.MapDParser.replaceIsTrue(final RelDataTypeFactory typeFactory, RelRoot root)

SqlNode com.mapd.calcite.parser.MapDParser.parseSql(String sql, final boolean legacy_syntax, Planner planner)

void com.mapd.calcite.parser.MapDParser.desugar(SqlSelect select_node, RelDataTypeFactory typeFactory)

SqlNode com.mapd.calcite.parser.MapDParser.expandCase(SqlCase old_case_node, RelDataTypeFactory typeFactory)

SqlOrderBy com.mapd.calcite.parser.MapDParser.desugar(SqlSelect select_node, SqlOrderBy order_by_node, RelDataTypeFactory typeFactory)

void com.mapd.calcite.parser.MapDParser.desugarExpression(SqlNode node, RelDataTypeFactory typeFactory)

SqlNode com.mapd.calcite.parser.MapDParser.expand(final SqlNode node, final java.util.Map< String, SqlNode > id_to_expr, RelDataTypeFactory typeFactory)

SqlNodeList com.mapd.calcite.parser.MapDParser.expand(final SqlNodeList group_by_list, final java.util.Map< String, SqlNode > id_to_expr, RelDataTypeFactory typeFactory)

SqlNode com.mapd.calcite.parser.MapDParser.expandVariance(final SqlBasicCall proj_call, RelDataTypeFactory typeFactory)

SqlNode com.mapd.calcite.parser.MapDParser.expandVariance(final SqlParserPos pos, final SqlNode operand, boolean biased, boolean sqrt, boolean flt, RelDataTypeFactory typeFactory)

SqlNode com.mapd.calcite.parser.MapDParser.expandCovariance(final SqlBasicCall proj_call, RelDataTypeFactory typeFactory)

SqlNode com.mapd.calcite.parser.MapDParser.expandCovariance(SqlParserPos pos, final SqlNode operand0, final SqlNode operand1, boolean pop, boolean flt, RelDataTypeFactory typeFactory)

SqlNode com.mapd.calcite.parser.MapDParser.expandCorrelation(final SqlBasicCall proj_call, RelDataTypeFactory typeFactory)

Private Members

final Supplier<MapDSqlOperatorTable> com.mapd.calcite.parser.MapDParser.mapDSqlOperatorTable

final String com.mapd.calcite.parser.MapDParser.dataDir

int com.mapd.calcite.parser.MapDParser.callCount = 0

final int com.mapd.calcite.parser.MapDParser.mapdPort

MapDUser com.mapd.calcite.parser.MapDParser.mapdUser

SockTransportProperties com.mapd.calcite.parser.MapDParser.sock_transport_properties = null

Private Static Attributes

final EnumSet<SqlKind> com.mapd.calcite.parser.MapDParser.SCALAR= EnumSet.of(SqlKind.SCALAR_QUERY, SqlKind.SELECT)

final EnumSet<SqlKind> com.mapd.calcite.parser.MapDParser.EXISTS = EnumSet.of(SqlKind.EXISTS)

final EnumSet<SqlKind> com.mapd.calcite.parser.MapDParser.DELETE = EnumSet.of(SqlKind.DELETE)

final EnumSet<SqlKind> com.mapd.calcite.parser.MapDParser.UPDATE = EnumSet.of(SqlKind.UPDATE)

final EnumSet<SqlKind> com.mapd.calcite.parser.MapDParser.IN = EnumSet.of(SqlKind.IN)

final EnumSet<SqlKind> com.mapd.calcite.parser.MapDParser.ARRAY_VALUE= EnumSet.of(SqlKind.ARRAY_VALUE_CONSTRUCTOR)

Map<String, Boolean> com.mapd.calcite.parser.MapDParser.SubqueryCorrMemo = new ConcurrentHashMap<>()

final Context com.mapd.calcite.parser.MapDParser.MAPD_CONNECTION_CONTEXT

class ExpressionListedAsChildOROperatorChecker : public org::apache::calcite::sql::util::SqlBasicVisitor<Void>

Public Functions

Void com.mapd.calcite.parser.MapDParser.ExpressionListedAsChildOROperatorChecker.visit(SqlCall call)

class ExpressionListedInSelectClauseChecker : public org::apache::calcite::sql::util::SqlBasicVisitor<Void>

Public Functions

Void com.mapd.calcite.parser.MapDParser.ExpressionListedInSelectClauseChecker.visit(SqlCall call)

class FindSqlOperator : public org::apache::calcite::sql::util::SqlBasicVisitor<Void>

Public Functions

Void com.mapd.calcite.parser.MapDParser.FindSqlOperator.visit(SqlCall call)

Private Members

SqlKind com.mapd.calcite.parser.MapDParser.FindSqlOperator.targetKind

class JoinOperatorChecker : public org::apache::calcite::sql::util::SqlBasicVisitor<Void>

Public Functions

boolean com.mapd.calcite.parser.MapDParser.JoinOperatorChecker.isEqualityJoinOperator(SqlBasicCall basicCall)

Void com.mapd.calcite.parser.MapDParser.JoinOperatorChecker.visit(SqlCall call)