org.apache.calcite.rel.core.Join.analyzeCondition()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(3.6k)|赞(0)|评价(0)|浏览(75)

本文整理了Java中org.apache.calcite.rel.core.Join.analyzeCondition()方法的一些代码示例,展示了Join.analyzeCondition()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Join.analyzeCondition()方法的具体详情如下:
包路径:org.apache.calcite.rel.core.Join
类名称:Join
方法名:analyzeCondition

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();

相关文章