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

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

本文整理了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

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

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

/**
 * Handle alter table <name> not stored as directories
 *
 * @param tableName
 * @param tab
 * @throws SemanticException
 */
private void handleAlterTableDisableStoredAsDirs(String tableName, Table tab)
  throws SemanticException {
List<String> skewedColNames = tab.getSkewedColNames();
 List<List<String>> skewedColValues = tab.getSkewedColValues();
 if ((skewedColNames == null) || (skewedColNames.size() == 0) || (skewedColValues == null)
   || (skewedColValues.size() == 0)) {
  throw new SemanticException(ErrorMsg.ALTER_TBL_STOREDASDIR_NOT_SKEWED.getMsg(tableName));
 }
 AlterTableDesc alterTblDesc = new AlterTableDesc(tableName, false,
   skewedColNames, skewedColValues);
 alterTblDesc.setStoredAsSubDirectories(false);
 rootTasks.add(TaskFactory.get(new DDLWork(getInputs(), getOutputs(),
   alterTblDesc)));
}

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

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

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

/**
 * Handle alter table <name> not stored as directories
 *
 * @param tableName
 * @param tab
 * @throws SemanticException
 */
private void handleAlterTableDisableStoredAsDirs(String tableName, Table tab)
  throws SemanticException {
List<String> skewedColNames = tab.getSkewedColNames();
 List<List<String>> skewedColValues = tab.getSkewedColValues();
 if ((skewedColNames == null) || (skewedColNames.size() == 0) || (skewedColValues == null)
   || (skewedColValues.size() == 0)) {
  throw new SemanticException(ErrorMsg.ALTER_TBL_STOREDASDIR_NOT_SKEWED.getMsg(tableName));
 }
 AlterTableDesc alterTblDesc = new AlterTableDesc(tableName, false,
   skewedColNames, skewedColValues);
 alterTblDesc.setStoredAsSubDirectories(false);
 rootTasks.add(TaskFactory.get(new DDLWork(getInputs(), getOutputs(),
   alterTblDesc), conf));
}

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

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

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

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

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

bucketCols = table.getBucketCols();
inputFormatClass = table.getInputFormatClass();
lbCtx = constructListBucketingCtx(table.getSkewedColNames(), table.getSkewedColValues(),
  table.getSkewedColValueLocationMaps(), table.isStoredAsSubDirectories());
isListBucketed = table.isStoredAsSubDirectories();

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

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

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

bucketCols = table.getBucketCols();
inputFormatClass = table.getInputFormatClass();
lbCtx = constructListBucketingCtx(table.getSkewedColNames(), table.getSkewedColValues(),
  table.getSkewedColValueLocationMaps(), table.isStoredAsSubDirectories(), conf);
isListBucketed = table.isStoredAsSubDirectories();

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

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

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

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

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

/**
 * Handle alter table <name> not stored as directories
 *
 * @param tableName
 * @param tab
 * @throws SemanticException
 */
private void handleAlterTableDisableStoredAsDirs(String tableName, Table tab)
  throws SemanticException {
List<String> skewedColNames = tab.getSkewedColNames();
 List<List<String>> skewedColValues = tab.getSkewedColValues();
 if ((skewedColNames == null) || (skewedColNames.size() == 0) || (skewedColValues == null)
   || (skewedColValues.size() == 0)) {
  throw new SemanticException(ErrorMsg.ALTER_TBL_STOREDASDIR_NOT_SKEWED.getMsg(tableName));
 }
 AlterTableDesc alterTblDesc = new AlterTableDesc(tableName, false,
   skewedColNames, skewedColValues);
 alterTblDesc.setStoredAsSubDirectories(false);
 rootTasks.add(TaskFactory.get(new DDLWork(getInputs(), getOutputs(),
   alterTblDesc), conf));
}

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

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

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

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

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

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

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

bucketCols = table.getBucketCols();
inputFormatClass = table.getInputFormatClass();
lbCtx = constructListBucketingCtx(table.getSkewedColNames(), table.getSkewedColValues(),
  table.getSkewedColValueLocationMaps(), table.isStoredAsSubDirectories(), conf);
isListBucketed = table.isStoredAsSubDirectories();

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

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

相关文章

微信公众号

最新文章

更多

Table类方法