org.apache.hadoop.hive.ql.metadata.Table.validatePartColumnNames()方法的使用及代码示例

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

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

Table.validatePartColumnNames介绍

暂无

代码示例

代码示例来源:origin: apache/hive

  1. public static void validatePartSpec(Table tbl, Map<String, String> partSpec,
  2. ASTNode astNode, HiveConf conf, boolean shouldBeFull) throws SemanticException {
  3. tbl.validatePartColumnNames(partSpec, shouldBeFull);
  4. validatePartColumnType(tbl, partSpec, astNode, conf);
  5. }

代码示例来源:origin: apache/drill

  1. public static void validatePartSpec(Table tbl, Map<String, String> partSpec,
  2. ASTNode astNode, HiveConf conf, boolean shouldBeFull) throws SemanticException {
  3. tbl.validatePartColumnNames(partSpec, shouldBeFull);
  4. validatePartColumnType(tbl, partSpec, astNode, conf);
  5. }

代码示例来源:origin: apache/hive

  1. private DynamicPartitionCtx checkDynPart(QB qb, QBMetaData qbm, Table dest_tab,
  2. Map<String, String> partSpec, String dest) throws SemanticException {
  3. List<FieldSchema> parts = dest_tab.getPartitionKeys();
  4. if (parts == null || parts.isEmpty()) {
  5. return null; // table is not partitioned
  6. }
  7. if (partSpec == null || partSpec.size() == 0) { // user did NOT specify partition
  8. throw new SemanticException(generateErrorMessage(qb.getParseInfo().getDestForClause(dest),
  9. ErrorMsg.NEED_PARTITION_ERROR.getMsg()));
  10. }
  11. DynamicPartitionCtx dpCtx = qbm.getDPCtx(dest);
  12. if (dpCtx == null) {
  13. dest_tab.validatePartColumnNames(partSpec, false);
  14. dpCtx = new DynamicPartitionCtx(partSpec,
  15. conf.getVar(HiveConf.ConfVars.DEFAULTPARTITIONNAME),
  16. conf.getIntVar(HiveConf.ConfVars.DYNAMICPARTITIONMAXPARTSPERNODE));
  17. qbm.setDPCtx(dest, dpCtx);
  18. }
  19. if (!HiveConf.getBoolVar(conf, HiveConf.ConfVars.DYNAMICPARTITIONING)) { // allow DP
  20. throw new SemanticException(generateErrorMessage(qb.getParseInfo().getDestForClause(dest),
  21. ErrorMsg.DYNAMIC_PARTITION_DISABLED.getMsg()));
  22. }
  23. if ((dest_tab.getNumBuckets() > 0)) {
  24. dpCtx.setNumBuckets(dest_tab.getNumBuckets());
  25. }
  26. return dpCtx;
  27. }

代码示例来源:origin: apache/hive

  1. tbl.validatePartColumnNames(partSpec, true);
  2. List<String> pvals = new ArrayList<String>();
  3. for (FieldSchema field : tbl.getPartCols()) {

代码示例来源:origin: apache/drill

  1. boolean forceCreate, String partPath, boolean inheritTableSpecs, List<Path> newFiles)
  2. throws HiveException {
  3. tbl.validatePartColumnNames(partSpec, true);
  4. List<String> pvals = new ArrayList<String>();
  5. for (FieldSchema field : tbl.getPartCols()) {

代码示例来源:origin: apache/drill

  1. dest_tab.validatePartColumnNames(partSpec, false);
  2. dpCtx = new DynamicPartitionCtx(dest_tab, partSpec,
  3. conf.getVar(HiveConf.ConfVars.DEFAULTPARTITIONNAME),

代码示例来源:origin: apache/hive

  1. destinationTable.validatePartColumnNames(partSpec, false);
  2. dpCtx = new DynamicPartitionCtx(partSpec,
  3. conf.getVar(HiveConf.ConfVars.DEFAULTPARTITIONNAME),

代码示例来源:origin: com.facebook.presto.hive/hive-apache

  1. public static void validatePartSpec(Table tbl, Map<String, String> partSpec,
  2. ASTNode astNode, HiveConf conf, boolean shouldBeFull) throws SemanticException {
  3. tbl.validatePartColumnNames(partSpec, shouldBeFull);
  4. validatePartColumnType(tbl, partSpec, astNode, conf);
  5. }

代码示例来源:origin: com.facebook.presto.hive/hive-apache

  1. dest_tab.validatePartColumnNames(partSpec, false);
  2. dpCtx = new DynamicPartitionCtx(dest_tab, partSpec,
  3. conf.getVar(HiveConf.ConfVars.DEFAULTPARTITIONNAME),

代码示例来源:origin: com.facebook.presto.hive/hive-apache

  1. boolean forceCreate, String partPath, boolean inheritTableSpecs, List<Path> newFiles)
  2. throws HiveException {
  3. tbl.validatePartColumnNames(partSpec, true);
  4. List<String> pvals = new ArrayList<String>();
  5. for (FieldSchema field : tbl.getPartCols()) {

相关文章

Table类方法