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

Utilities.getDPColOffset介绍

暂无

代码示例

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

/**
 * Set up for dynamic partitioning including a new ObjectInspector for the output row.
 */
private void dpSetup() {
 this.bDynParts = false;
 this.numDynParts = dpCtx.getNumDPCols();
 this.dpColNames = dpCtx.getDPColNames();
 this.maxPartitions = dpCtx.getMaxPartitionsPerNode();
 assert numDynParts == dpColNames.size()
   : "number of dynamic partitions should be the same as the size of DP mapping";
 if (dpColNames != null && dpColNames.size() > 0) {
  this.bDynParts = true;
  assert inputObjInspectors.length == 1 : "FileSinkOperator should have 1 parent, but it has "
    + inputObjInspectors.length;
  StructObjectInspector soi = (StructObjectInspector) inputObjInspectors[0];
  this.dpStartCol = Utilities.getDPColOffset(conf);
  this.subSetOI = new SubStructObjectInspector(soi, 0, this.dpStartCol);
  this.dpVals = new ArrayList<String>(numDynParts);
  this.dpWritables = new ArrayList<Object>(numDynParts);
 }
}

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

/**
 * Set up for dynamic partitioning including a new ObjectInspector for the output row.
 */
private void dpSetup() {
 this.bDynParts = false;
 this.numDynParts = dpCtx.getNumDPCols();
 this.dpColNames = dpCtx.getDPColNames();
 this.maxPartitions = dpCtx.getMaxPartitionsPerNode();
 assert numDynParts == dpColNames.size()
   : "number of dynamic partitions should be the same as the size of DP mapping";
 if (dpColNames != null && dpColNames.size() > 0) {
  this.bDynParts = true;
  assert inputObjInspectors.length == 1 : "FileSinkOperator should have 1 parent, but it has "
    + inputObjInspectors.length;
  StructObjectInspector soi = (StructObjectInspector) inputObjInspectors[0];
  this.dpStartCol = Utilities.getDPColOffset(conf);
  this.subSetOI = new SubStructObjectInspector(soi, 0, this.dpStartCol);
  this.dpVals = new ArrayList<String>(numDynParts);
  this.dpWritables = new ArrayList<Object>(numDynParts);
 }
}

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

RowSchema rs = parent.getSchema();
boolean allConstant = true;
int dpColStartIdx = Utilities.getDPColOffset(fsdesc);
List<ColumnInfo> colInfos = rs.getSignature();
for (int i = dpColStartIdx; i < colInfos.size(); i++) {

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

RowSchema rs = parent.getSchema();
boolean allConstant = true;
int dpColStartIdx = Utilities.getDPColOffset(fsdesc);
List<ColumnInfo> colInfos = rs.getSignature();
for (int i = dpColStartIdx; i < colInfos.size(); i++) {