本文整理了Java中org.apache.calcite.rel.core.Join.analyzeCondition()
方法的一些代码示例,展示了Join.analyzeCondition()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Join.analyzeCondition()
方法的具体详情如下:
包路径:org.apache.calcite.rel.core.Join
类名称:Join
方法名:analyzeCondition
[英]Analyzes the join condition.
[中]分析连接条件。
代码示例来源:origin: apache/hive
return;
final JoinInfo joinInfo = join.analyzeCondition();
if (!joinInfo.rightSet().equals(
ImmutableBitSet.range(aggregate.getGroupCount()))) {
代码示例来源:origin: apache/hive
final JoinInfo joinInfo = join.analyzeCondition();
if(!joinInfo.isEqui()) {
return;
代码示例来源:origin: apache/drill
return;
final JoinInfo joinInfo = join.analyzeCondition();
if (!joinInfo.rightSet().equals(
ImmutableBitSet.range(aggregate.getGroupCount()))) {
代码示例来源:origin: apache/incubator-druid
final JoinInfo joinInfo = join.analyzeCondition();
代码示例来源:origin: org.apache.calcite/calcite-core
final JoinInfo joinInfo = rel.analyzeCondition();
代码示例来源:origin: Qihoo360/Quicksql
final JoinInfo joinInfo = rel.analyzeCondition();
代码示例来源:origin: com.alibaba.blink/flink-table
private static boolean isAggregateKeyApplicable(ImmutableBitSet aggregateKeys, Join join) {
JoinInfo joinInfo = join.analyzeCondition();
return (join.getJoinType() == JoinRelType.LEFT && joinInfo.leftSet().contains(aggregateKeys)) ||
(join.getJoinType() == JoinRelType.RIGHT &&
joinInfo.rightSet().shift(join.getInput(0).getRowType().getFieldCount())
.contains(aggregateKeys));
}
代码示例来源:origin: org.apache.calcite/calcite-core
for (IntPair p : join.analyzeCondition().pairs()) {
final ColRef source = left.column(p.source);
final ColRef target = right.column(p.target);
代码示例来源:origin: Qihoo360/Quicksql
rexBuilder.makeCall(SqlStdOperatorTable.IS_NOT_NULL, iRef),
trueLiteral);
final JoinInfo joinInfo = join.analyzeCondition();
for (int leftKey : joinInfo.leftKeys) {
final RexNode kRef = rexBuilder.makeInputRef(root, leftKey);
代码示例来源:origin: org.apache.calcite/calcite-core
rexBuilder.makeCall(SqlStdOperatorTable.IS_NOT_NULL, iRef),
trueLiteral);
final JoinInfo joinInfo = join.analyzeCondition();
for (int leftKey : joinInfo.leftKeys) {
final RexNode kRef = rexBuilder.makeInputRef(root, leftKey);
代码示例来源:origin: org.apache.kylin/atopcalcite
rexBuilder.makeCall(SqlStdOperatorTable.IS_NOT_NULL, iRef),
trueLiteral);
final JoinInfo joinInfo = join.analyzeCondition();
for (int leftKey : joinInfo.leftKeys) {
final RexNode kRef = rexBuilder.makeInputRef(root, leftKey);
代码示例来源:origin: Qihoo360/Quicksql
final JoinInfo joinInfo = origJoinRel.analyzeCondition();
if (joinInfo.leftKeys.size() == 0) {
return;
代码示例来源:origin: org.apache.calcite/calcite-core
final JoinInfo joinInfo = origJoinRel.analyzeCondition();
if (joinInfo.leftKeys.size() == 0) {
return;
代码示例来源:origin: org.apache.calcite/calcite-core
final JoinInfo joinInfo = join.analyzeCondition();
if (!joinInfo.rightSet().equals(
ImmutableBitSet.range(aggregate.getGroupCount()))) {
代码示例来源:origin: Qihoo360/Quicksql
final JoinInfo joinInfo = join.analyzeCondition();
if (!joinInfo.rightSet().equals(
ImmutableBitSet.range(aggregate.getGroupCount()))) {
代码示例来源:origin: Qihoo360/Quicksql
final JoinInfo joinInfo = rel.analyzeCondition();
if (leftColumns.cardinality() > 0) {
if (rel.getJoinType().generatesNullsOnLeft()) {
代码示例来源:origin: org.apache.calcite/calcite-core
final JoinInfo joinInfo = rel.analyzeCondition();
if (leftColumns.cardinality() > 0) {
if (rel.getJoinType().generatesNullsOnLeft()) {
代码示例来源:origin: org.apache.flink/flink-table_2.10
rexBuilder.makeCall(SqlStdOperatorTable.IS_NOT_NULL, iRef),
trueLiteral);
final JoinInfo joinInfo = join.analyzeCondition();
for (int leftKey : joinInfo.leftKeys) {
final RexNode kRef = rexBuilder.makeInputRef(root, leftKey);
代码示例来源:origin: org.apache.druid/druid-sql
final JoinInfo joinInfo = join.analyzeCondition();
内容来源于网络,如有侵权,请联系作者删除!