本文整理了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
暂无
代码示例来源: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);
}
内容来源于网络,如有侵权,请联系作者删除!