本文整理了Java中org.apache.tez.dag.api.Vertex.getInputVertices()
方法的一些代码示例,展示了Vertex.getInputVertices()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Vertex.getInputVertices()
方法的具体详情如下:
包路径:org.apache.tez.dag.api.Vertex
类名称:Vertex
方法名:getInputVertices
[英]Get the input vertices for this vertex
[中]获取该顶点的输入顶点
代码示例来源:origin: apache/hive
private long hiveInputRecordsFromOtherVertices(String vertexName) {
List<Vertex> inputVerticesList = dag.getVertex(vertexName).getInputVertices();
long result = 0;
for (Vertex inputVertex : inputVerticesList) {
long inputVertexRecords = hiveInputRecordsFromTezCounters(vertexName, inputVertex.getName());
if (inputVertexRecords < 0) {
inputVertexRecords = hiveInputRecordsFromHiveCounters(inputVertex.getName());
}
result += inputVertexRecords;
}
return result;
}
代码示例来源:origin: apache/drill
private long hiveInputRecordsFromOtherVertices(String vertexName) {
List<Vertex> inputVerticesList = dag.getVertex(vertexName).getInputVertices();
long result = 0;
for (Vertex inputVertex : inputVerticesList) {
long inputVertexRecords = hiveInputRecordsFromTezCounters(vertexName, inputVertex.getName());
if (inputVertexRecords < 0) {
inputVertexRecords = hiveInputRecordsFromHiveCounters(inputVertex.getName());
}
result += inputVertexRecords;
}
return result;
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
List<Vertex> inputVerticesList = currentVertex.getInputVertices();
long hiveInputRecordsFromOtherVertices = 0;
if (inputVerticesList.size() > 0) {
代码示例来源:origin: org.apache.tez/tez-api
if (vertex.getInputVertices()!= null && !vertex.getInputVertices().isEmpty()) {
for (Vertex srcVertex : vertex.getInputVertices()) {
if (srcVertex.getParallelism() == -1) {
has1to1UninitedSources = true;
内容来源于网络,如有侵权,请联系作者删除!