本文整理了Java中org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatchCtx.getRowColumnNames()
方法的一些代码示例,展示了VectorizedRowBatchCtx.getRowColumnNames()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。VectorizedRowBatchCtx.getRowColumnNames()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatchCtx
类名称:VectorizedRowBatchCtx
方法名:getRowColumnNames
暂无
代码示例来源:origin: apache/drill
private List<String> getColumns(int startIndex, int count) {
String[] rowColumnNames = vectorizedRowBatchCtx.getRowColumnNames();
TypeInfo[] rowColumnTypeInfos = vectorizedRowBatchCtx.getRowColumnTypeInfos();
List<String> result = new ArrayList<String>(count);
final int end = startIndex + count;
for (int i = startIndex; i < end; i++) {
result.add(rowColumnNames[i] + ":" + rowColumnTypeInfos[i]);
}
return result;
}
代码示例来源:origin: apache/drill
public void debugDisplayAllMaps(BaseWork work) {
VectorizedRowBatchCtx vectorizedRowBatchCtx = work.getVectorizedRowBatchCtx();
String[] allColumnNames = vectorizedRowBatchCtx.getRowColumnNames();
Object columnTypeInfos = vectorizedRowBatchCtx.getRowColumnTypeInfos();
int partitionColumnCount = vectorizedRowBatchCtx.getPartitionColumnCount();
String[] scratchColumnTypeNames =vectorizedRowBatchCtx.getScratchColumnTypeNames();
LOG.debug("debugDisplayAllMaps allColumnNames " + Arrays.toString(allColumnNames));
LOG.debug("debugDisplayAllMaps columnTypeInfos " + Arrays.deepToString((Object[]) columnTypeInfos));
LOG.debug("debugDisplayAllMaps partitionColumnCount " + partitionColumnCount);
LOG.debug("debugDisplayAllMaps scratchColumnTypeNames " + Arrays.toString(scratchColumnTypeNames));
}
}
代码示例来源: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
final String[] rowColumnNames = batchContext.getRowColumnNames();
final TypeInfo[] rowColumnTypeInfos = batchContext.getRowColumnTypeInfos();
tableStructTypeInfo =
代码示例来源:origin: apache/drill
final String[] rowColumnNames = batchContext.getRowColumnNames();
final TypeInfo[] rowColumnTypeInfos = batchContext.getRowColumnTypeInfos();
tableStructTypeInfo =
内容来源于网络,如有侵权,请联系作者删除!