public class HiveJdbcConverter extends org.apache.calcite.rel.convert.ConverterImpl implements HiveRelNode
CONVENTION
Constructor and Description |
---|
HiveJdbcConverter(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traits,
org.apache.calcite.rel.RelNode input,
org.apache.calcite.adapter.jdbc.JdbcConvention jc,
String url,
String user) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
List<org.apache.calcite.rel.RelNode> inputs) |
org.apache.calcite.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode input) |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
String |
generateSql() |
String |
getConnectionUrl() |
String |
getConnectionUser() |
org.apache.calcite.adapter.jdbc.JdbcConvention |
getJdbcConvention() |
org.apache.calcite.sql.SqlDialect |
getJdbcDialect() |
JdbcHiveTableScan |
getTableScan() |
boolean |
splittingAllowed()
Whether the execution of the query below this jdbc converter
can be split by Hive.
|
cannotImplement, computeSelfCost, getInputTraits, getTraitDef
childrenAccept, deriveRowType, estimateRowCount, getInput, getInputs, replaceInput
accept, accept, collectVariablesSet, collectVariablesUsed, deepEquals, deepHashCode, equals, explain, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getRelDigest, getRelTypeName, getRowType, getTable, getTraitSet, getVariablesSet, hashCode, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, sole, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, deepEquals, deepHashCode, estimateRowCount, explain, getConvention, getCorrelVariable, getDigest, getExpectedInputRowType, getInput, getInputs, getRelDigest, getRelTypeName, getRowType, getTable, getVariablesSet, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
explainTerms
in class org.apache.calcite.rel.SingleRel
public org.apache.calcite.adapter.jdbc.JdbcConvention getJdbcConvention()
public org.apache.calcite.sql.SqlDialect getJdbcDialect()
public String getConnectionUrl()
public String getConnectionUser()
public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
copy
in interface org.apache.calcite.rel.RelNode
copy
in class org.apache.calcite.rel.AbstractRelNode
public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode input)
public String generateSql()
public boolean splittingAllowed()
public JdbcHiveTableScan getTableScan()
Copyright © 2023 The Apache Software Foundation. All rights reserved.