2017-07-28 81 views

回答

0

如果您使用Hive运行查询,则无法使用自定义DAG。如果您使用API​​对Tez应用程序进行低级编程,则可以。见高级别文档浏览:https://hortonworks.com/blog/expressing-data-processing-in-apache-tez/

事情是这样的:

//Define DAG 
DAG dag = new DAG(); 
Vertex map1 = new Vertex(MapProcessor.class) 
and so on... 

见Apache项目的例子:https://git-wip-us.apache.org/repos/asf?p=tez.git;a=blob;f=tez-examples/src/main/java/org/apache/tez/examples/HashJoinExample.java