本文整理了Java中org.apache.tez.dag.api.Vertex.getDataSinks()
方法的一些代码示例,展示了Vertex.getDataSinks()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Vertex.getDataSinks()
方法的具体详情如下:
包路径:org.apache.tez.dag.api.Vertex
类名称:Vertex
方法名:getDataSinks
暂无
代码示例来源:origin: org.apache.tez/tez-api
addFileSystemCredentialsFromURIs(dataSource.getURIsForCredentials(), dagCredentials, conf);
List<DataSinkDescriptor> dataSinks = v.getDataSinks();
for (DataSinkDescriptor dataSink : dataSinks) {
addFileSystemCredentialsFromURIs(dataSink.getURIsForCredentials(), dagCredentials, conf);
代码示例来源:origin: org.apache.tez/tez-tests
MROutputLegacy.createConfigBuilder(finalReduceConf, TextOutputFormat.class, outputPath)
.build());
finalReduceVertex.getDataSinks().get(0).getOutputDescriptor().setHistoryText(
TezUtils.convertToHistoryText("HDFS Output " + outputPath, finalReduceConf));
vertices.add(finalReduceVertex);
代码示例来源:origin: org.apache.tez/tez-api
"vertex task location hint must equal vertex parallelism. Vertex: " + vertex.getName());
for (DataSinkDescriptor dataSink : vertex.getDataSinks()) {
if (dataSink.getCredentials() != null) {
dagCredentials.addAll(dataSink.getCredentials());
内容来源于网络,如有侵权,请联系作者删除!