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

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

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

Utilities.removeValueTag介绍

暂无

代码示例

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

int index = valColNames.indexOf(Utilities.removeValueTag(childCol.getFieldName()));
if (index < 0) {
 continue;

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

int index = valColNames.indexOf(Utilities.removeValueTag(childCol.getFieldName()));
if (index < 0) {
 continue;

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

@Override
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx,
  Object... nodeOutputs) throws SemanticException {
 ExprNodeColumnDesc cd = (ExprNodeColumnDesc) nd;
 ExprProcCtx epc = (ExprProcCtx) procCtx;
 // assert that the input operator is not null as there are no
 // exprs associated with table scans.
 Operator<? extends OperatorDesc> operator = epc.getInputOperator();
 assert (operator != null);
 RowSchema schema = epc.getSchema();
 ColumnInfo ci = schema.getColumnInfo(cd.getColumn());
 if (ci == null && operator instanceof ReduceSinkOperator) {
  ci = schema.getColumnInfo(Utilities.removeValueTag(cd.getColumn()));
 }
 // Insert the dependencies of inp_ci to that of the current operator, ci
 LineageCtx lc = epc.getLineageCtx();
 Dependency dep = lc.getIndex().getDependency(operator, ci);
 return dep;
}

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

@Override
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx,
  Object... nodeOutputs) throws SemanticException {
 ExprNodeColumnDesc cd = (ExprNodeColumnDesc) nd;
 ExprProcCtx epc = (ExprProcCtx) procCtx;
 // assert that the input operator is not null as there are no
 // exprs associated with table scans.
 Operator<? extends OperatorDesc> operator = epc.getInputOperator();
 assert (operator != null);
 RowSchema schema = epc.getSchema();
 ColumnInfo ci = schema.getColumnInfo(cd.getColumn());
 if (ci == null && operator instanceof ReduceSinkOperator) {
  ci = schema.getColumnInfo(Utilities.removeValueTag(cd.getColumn()));
 }
 // Insert the dependencies of inp_ci to that of the current operator, ci
 LineageCtx lc = epc.getLineageCtx();
 Dependency dep = lc.getIndex().getDependency(operator, ci);
 return dep;
}

代码示例来源:origin: com.facebook.presto.hive/hive-apache

int index = valColNames.indexOf(Utilities.removeValueTag(childCol));
if (index < 0) {
 continue;

代码示例来源:origin: com.facebook.presto.hive/hive-apache

@Override
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx,
  Object... nodeOutputs) throws SemanticException {
 ExprNodeColumnDesc cd = (ExprNodeColumnDesc) nd;
 ExprProcCtx epc = (ExprProcCtx) procCtx;
 // assert that the input operator is not null as there are no
 // exprs associated with table scans.
 Operator<? extends OperatorDesc> operator = epc.getInputOperator();
 assert (operator != null);
 RowSchema schema = epc.getSchema();
 ColumnInfo ci = schema.getColumnInfo(cd.getColumn());
 if (ci == null && operator instanceof ReduceSinkOperator) {
  ci = schema.getColumnInfo(Utilities.removeValueTag(cd.getColumn()));
 }
 // Insert the dependencies of inp_ci to that of the current operator, ci
 LineageCtx lc = epc.getLineageCtx();
 Dependency dep = lc.getIndex().getDependency(operator, ci);
 return dep;
}

相关文章

Utilities类方法