org.apache.hadoop.hive.ql.exec.Utilities.getBucketingVersion()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(89)

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

Utilities.getBucketingVersion介绍

暂无

代码示例

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

public int getBucketingVersion() {
 return Utilities.getBucketingVersion(
   properties.getProperty(hive_metastoreConstants.TABLE_BUCKETING_VERSION));
}

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

public int getBucketingVersion() {
 return Utilities.getBucketingVersion(
   getProperty(hive_metastoreConstants.TABLE_BUCKETING_VERSION));
}

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

protected int getBucket(Object row) {
 if (!isBucketed) {
  return 0;
 }
 Object[] bucketFields = getBucketFields(row);
 int bucketingVersion = Utilities.getBucketingVersion(
  table.getParameters().get(hive_metastoreConstants.TABLE_BUCKETING_VERSION));
 return bucketingVersion == 2 ?
  ObjectInspectorUtils.getBucketNumber(bucketFields, bucketObjInspectors, totalBuckets) :
  ObjectInspectorUtils.getBucketNumberOld(bucketFields, bucketObjInspectors, totalBuckets);
}

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

protected int getBucket(Object row) throws SerializationError {
 if(!isBucketed) {
  return 0;
 }
 ObjectInspector[] inspectors = getBucketObjectInspectors();
 Object[] bucketFields = getBucketFields(row);
 int bucketingVersion = Utilities.getBucketingVersion(
   tbl.getParameters().get(hive_metastoreConstants.TABLE_BUCKETING_VERSION));
 return bucketingVersion == 2 ?
   ObjectInspectorUtils.getBucketNumber(bucketFields, inspectors, totalBuckets) :
   ObjectInspectorUtils.getBucketNumberOld(bucketFields, inspectors, totalBuckets);
}

代码示例来源:origin: org.apache.hive/hive-streaming

protected int getBucket(Object row) {
 if (!isBucketed) {
  return 0;
 }
 Object[] bucketFields = getBucketFields(row);
 int bucketingVersion = Utilities.getBucketingVersion(
  table.getParameters().get(hive_metastoreConstants.TABLE_BUCKETING_VERSION));
 return bucketingVersion == 2 ?
  ObjectInspectorUtils.getBucketNumber(bucketFields, bucketObjInspectors, totalBuckets) :
  ObjectInspectorUtils.getBucketNumberOld(bucketFields, bucketObjInspectors, totalBuckets);
}

相关文章

微信公众号

最新文章

更多

Utilities类方法