Package org.apache.hadoop.hive.ql.optimizer.optiq

Examples of org.apache.hadoop.hive.ql.optimizer.optiq.RelOptHiveTable

235
236
237
238
239
240
241
242
243
244
245
      expr = RelOptUtil.pushFilterPastProject(expr, (ProjectRelBase) r);
      return isPartitionPredicate(expr, ((ProjectRelBase) r).getChild());
    } else if (r instanceof FilterRelBase) {
      return isPartitionPredicate(expr, ((FilterRelBase) r).getChild());
    } else if (r instanceof HiveTableScanRel) {
      RelOptHiveTable table = (RelOptHiveTable) ((HiveTableScanRel) r).getTable();
      BitSet cols = RelOptUtil.InputFinder.bits(expr);
      return table.containsPartitionColumnsOnly(cols);
    }
    return false;
  }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
            ASTBuilder.construct(HiveParser.TOK_DIR, "TOK_DIR").add(HiveParser.TOK_TMP_FILE,
                "TOK_TMP_FILE")).node();
  }

  static ASTNode table(TableAccessRelBase scan) {
    RelOptHiveTable hTbl = (RelOptHiveTable) scan.getTable();
    ASTBuilder b = ASTBuilder.construct(HiveParser.TOK_TABREF, "TOK_TABREF").add(
        ASTBuilder.construct(HiveParser.TOK_TABNAME, "TOK_TABNAME")
            .add(HiveParser.Identifier, hTbl.getHiveTableMD().getDbName())
            .add(HiveParser.Identifier, hTbl.getHiveTableMD().getTableName()));

    // NOTE: Optiq considers tbls to be equal if their names are the same. Hence
    // we need to provide Optiq the fully qualified table name (dbname.tblname)
    // and not the user provided aliases.
    // However in HIVE DB name can not appear in select list; in case of join
    // where table names differ only in DB name, Hive would require user
    // introducing explicit aliases for tbl.
    b.add(HiveParser.Identifier, hTbl.getTableAlias());
    return b.node();
  }
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
55
56
  }

  protected void perform(RelOptRuleCall call, FilterRelBase filter,
      HiveTableScanRel tScan) {

    RelOptHiveTable hiveTable = (RelOptHiveTable) tScan.getTable();
    RexNode predicate = filter.getCondition();

    Pair<RexNode, RexNode> predicates = PartitionPruner
        .extractPartitionPredicates(filter.getCluster(), hiveTable, predicate);
    RexNode partColExpr = predicates.left;
    hiveTable.computePartitionList(conf, partColExpr);
  }
View Full Code Here
13094
13095
13096
13097
13098
13099
13100
13101
13102
13103
13104
        String fullyQualifiedTabName = tab.getDbName();
        if (fullyQualifiedTabName != null && !fullyQualifiedTabName.isEmpty())
          fullyQualifiedTabName = fullyQualifiedTabName + "." + tab.getTableName();
        else
          fullyQualifiedTabName = tab.getTableName();
        RelOptHiveTable optTable = new RelOptHiveTable(relOptSchema, fullyQualifiedTabName,
            tableAlias, rowType, tab, nonPartitionColumns, partitionColumns, conf, partitionCache,
            noColsMissingStats);

        // 5. Build Hive Table Scan Rel
        tableRel = new HiveTableScanRel(cluster, cluster.traitSetOf(HiveRel.CONVENTION), optTable,
View Full Code Here
TOP

Related Classes of org.apache.hadoop.hive.ql.optimizer.optiq.RelOptHiveTable

  • org.apache.hadoop.hive.ql.exec.ColumnInfo
  • org.apache.hadoop.hive.ql.optimizer.optiq.rules.HivePartitionPrunerRule
  • org.apache.hadoop.hive.ql.optimizer.optiq.stats.FilterSelectivityEstimator
  • org.apache.hadoop.hive.ql.optimizer.optiq.translator.ASTBuilder
  • org.apache.hadoop.hive.ql.optimizer.optiq.translator.ExprNodeConverter
  • org.apache.hadoop.hive.ql.parse.SemanticAnalyzer$OptiqBasedPlanner
  • org.apache.hadoop.hive.ql.plan.ColStatistics
  • org.apache.hadoop.hive.ql.plan.ExprNodeDesc
  • org.apache.hadoop.hive.ql.plan.Statistics
  • org.eigenbase.rel.TableAccessRel
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.