本文整理了Java中org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatchCtx.getRowdataTypePhysicalVariations()
方法的一些代码示例,展示了VectorizedRowBatchCtx.getRowdataTypePhysicalVariations()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。VectorizedRowBatchCtx.getRowdataTypePhysicalVariations()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatchCtx
类名称:VectorizedRowBatchCtx
方法名:getRowdataTypePhysicalVariations
暂无
代码示例来源:origin: apache/hive
public static List<String> getColumns(VectorizedRowBatchCtx vectorizedRowBatchCtx,
int startIndex, int count) {
String[] rowColumnNames = vectorizedRowBatchCtx.getRowColumnNames();
TypeInfo[] rowColumnTypeInfos = vectorizedRowBatchCtx.getRowColumnTypeInfos();
DataTypePhysicalVariation[] dataTypePhysicalVariations =
vectorizedRowBatchCtx.getRowdataTypePhysicalVariations();
List<String> result = new ArrayList<String>(count);
final int end = startIndex + count;
for (int i = startIndex; i < end; i++) {
String displayString = rowColumnNames[i] + ":" + rowColumnTypeInfos[i];
if (dataTypePhysicalVariations != null &&
dataTypePhysicalVariations[i] != DataTypePhysicalVariation.NONE) {
displayString += "/" + dataTypePhysicalVariations[i].toString();
}
result.add(displayString);
}
return result;
}
代码示例来源:origin: apache/hive
this.sourceBatch = vrbCtx.createVectorizedRowBatch();
deserializeRead = new LazySimpleDeserializeRead(vrbCtx.getRowColumnTypeInfos(),
vrbCtx.getRowdataTypePhysicalVariations(),/* useExternalBuffer */ true, createSerdeParams(conf, tblProps));
vectorDeserializeRow = new VectorDeserializeRow<LazySimpleDeserializeRead>(deserializeRead);
int colCount = vrbCtx.getRowColumnTypeInfos().length;
代码示例来源:origin: apache/hive
new LazySimpleDeserializeRead(
minimalDataTypeInfos,
batchContext.getRowdataTypePhysicalVariations(),
/* useExternalBuffer */ true,
simpleSerdeParams);
代码示例来源:origin: org.apache.hive/hive-llap-server
this.sourceBatch = vrbCtx.createVectorizedRowBatch();
deserializeRead = new LazySimpleDeserializeRead(vrbCtx.getRowColumnTypeInfos(),
vrbCtx.getRowdataTypePhysicalVariations(),/* useExternalBuffer */ true, createSerdeParams(conf, tblProps));
vectorDeserializeRow = new VectorDeserializeRow<LazySimpleDeserializeRead>(deserializeRead);
int colCount = vrbCtx.getRowColumnTypeInfos().length;
内容来源于网络,如有侵权,请联系作者删除!