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

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

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

Table.getSkewedColValues介绍

暂无

代码示例

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

  1. table == null ? null : table.getSkewedColValues();

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

  1. /**
  2. * Handle alter table <name> not stored as directories
  3. *
  4. * @param tableName
  5. * @param tab
  6. * @throws SemanticException
  7. */
  8. private void handleAlterTableDisableStoredAsDirs(String tableName, Table tab)
  9. throws SemanticException {
  10. List<String> skewedColNames = tab.getSkewedColNames();
  11. List<List<String>> skewedColValues = tab.getSkewedColValues();
  12. if ((skewedColNames == null) || (skewedColNames.size() == 0) || (skewedColValues == null)
  13. || (skewedColValues.size() == 0)) {
  14. throw new SemanticException(ErrorMsg.ALTER_TBL_STOREDASDIR_NOT_SKEWED.getMsg(tableName));
  15. }
  16. AlterTableDesc alterTblDesc = new AlterTableDesc(tableName, false,
  17. skewedColNames, skewedColValues);
  18. alterTblDesc.setStoredAsSubDirectories(false);
  19. rootTasks.add(TaskFactory.get(new DDLWork(getInputs(), getOutputs(),
  20. alterTblDesc)));
  21. }

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

  1. table == null ? null : table.getSkewedColValues();

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

  1. /**
  2. * Handle alter table <name> not stored as directories
  3. *
  4. * @param tableName
  5. * @param tab
  6. * @throws SemanticException
  7. */
  8. private void handleAlterTableDisableStoredAsDirs(String tableName, Table tab)
  9. throws SemanticException {
  10. List<String> skewedColNames = tab.getSkewedColNames();
  11. List<List<String>> skewedColValues = tab.getSkewedColValues();
  12. if ((skewedColNames == null) || (skewedColNames.size() == 0) || (skewedColValues == null)
  13. || (skewedColValues.size() == 0)) {
  14. throw new SemanticException(ErrorMsg.ALTER_TBL_STOREDASDIR_NOT_SKEWED.getMsg(tableName));
  15. }
  16. AlterTableDesc alterTblDesc = new AlterTableDesc(tableName, false,
  17. skewedColNames, skewedColValues);
  18. alterTblDesc.setStoredAsSubDirectories(false);
  19. rootTasks.add(TaskFactory.get(new DDLWork(getInputs(), getOutputs(),
  20. alterTblDesc), conf));
  21. }

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

  1. newTblPartLoc = tblObj.getPath();
  2. lbCtx = constructListBucketingCtx(tblObj.getSkewedColNames(), tblObj.getSkewedColValues(),
  3. tblObj.getSkewedColValueLocationMaps(), tblObj.isStoredAsSubDirectories(), conf);

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

  1. newTblPartLoc = tblObj.getPath();
  2. lbCtx = constructListBucketingCtx(tblObj.getSkewedColNames(), tblObj.getSkewedColValues(),
  3. tblObj.getSkewedColValueLocationMaps(), tblObj.isStoredAsSubDirectories());

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

  1. bucketCols = table.getBucketCols();
  2. inputFormatClass = table.getInputFormatClass();
  3. lbCtx = constructListBucketingCtx(table.getSkewedColNames(), table.getSkewedColValues(),
  4. table.getSkewedColValueLocationMaps(), table.isStoredAsSubDirectories());
  5. isListBucketed = table.isStoredAsSubDirectories();

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

  1. dest_tab.getSkewedColValues(), dest_tab.getSkewedColValueLocationMaps(),
  2. dest_tab.isStoredAsSubDirectories(), conf);

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

  1. bucketCols = table.getBucketCols();
  2. inputFormatClass = table.getInputFormatClass();
  3. lbCtx = constructListBucketingCtx(table.getSkewedColNames(), table.getSkewedColValues(),
  4. table.getSkewedColValueLocationMaps(), table.isStoredAsSubDirectories(), conf);
  5. isListBucketed = table.isStoredAsSubDirectories();

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

  1. destinationTable.getSkewedColValues(), destinationTable.getSkewedColValueLocationMaps(),
  2. destinationTable.isStoredAsSubDirectories());

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

  1. table == null ? null : table.getSkewedColValues();

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

  1. /**
  2. * Handle alter table <name> not stored as directories
  3. *
  4. * @param tableName
  5. * @param tab
  6. * @throws SemanticException
  7. */
  8. private void handleAlterTableDisableStoredAsDirs(String tableName, Table tab)
  9. throws SemanticException {
  10. List<String> skewedColNames = tab.getSkewedColNames();
  11. List<List<String>> skewedColValues = tab.getSkewedColValues();
  12. if ((skewedColNames == null) || (skewedColNames.size() == 0) || (skewedColValues == null)
  13. || (skewedColValues.size() == 0)) {
  14. throw new SemanticException(ErrorMsg.ALTER_TBL_STOREDASDIR_NOT_SKEWED.getMsg(tableName));
  15. }
  16. AlterTableDesc alterTblDesc = new AlterTableDesc(tableName, false,
  17. skewedColNames, skewedColValues);
  18. alterTblDesc.setStoredAsSubDirectories(false);
  19. rootTasks.add(TaskFactory.get(new DDLWork(getInputs(), getOutputs(),
  20. alterTblDesc), conf));
  21. }

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

  1. for (List<String> value : tbl.getSkewedColValues()) {
  2. XSkewColList colVallist = new XSkewColList();
  3. colVallist.getElements().addAll(value);

代码示例来源:origin: org.apache.lens/lens-cube

  1. for (List<String> value : tbl.getSkewedColValues()) {
  2. XSkewColList colVallist = new XSkewColList();
  3. colVallist.getElements().addAll(value);

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

  1. newTblPartLoc = tblObj.getPath();
  2. lbCtx = constructListBucketingCtx(tblObj.getSkewedColNames(), tblObj.getSkewedColValues(),
  3. tblObj.getSkewedColValueLocationMaps(), tblObj.isStoredAsSubDirectories(), conf);

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

  1. bucketCols = table.getBucketCols();
  2. inputFormatClass = table.getInputFormatClass();
  3. lbCtx = constructListBucketingCtx(table.getSkewedColNames(), table.getSkewedColValues(),
  4. table.getSkewedColValueLocationMaps(), table.isStoredAsSubDirectories(), conf);
  5. isListBucketed = table.isStoredAsSubDirectories();

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

  1. dest_tab.getSkewedColValues(), dest_tab.getSkewedColValueLocationMaps(),
  2. dest_tab.isStoredAsSubDirectories(), conf);

相关文章

Table类方法