Package org.apache.tez.dag.app.dag

Examples of org.apache.tez.dag.app.dag.RootInputInitializerRunner$InputInitializerCallback

1536
1537
1538
1539
1540
1541
1542
1543
  @VisibleForTesting
  protected RootInputInitializerRunner createRootInputInitializerRunner(
      String dagName, String vertexName, TezVertexID vertexID,
      EventHandler eventHandler, int numTasks, int numNodes,
      Resource vertexTaskResource, Resource totalResource) {
    return new RootInputInitializerRunner(dagName, vertexName, vertexID,
        eventHandler, dagUgi, vertexTaskResource, totalResource, numTasks, numNodes);
  }
View Full Code Here
1396
1397
1398
1399
1400
1401
1402
1403
  @VisibleForTesting
  protected RootInputInitializerRunner createRootInputInitializerRunner(
      String dagName, String vertexName, TezVertexID vertexID,
      EventHandler eventHandler, int numTasks) {
    return new RootInputInitializerRunner(dagName, vertexName, vertexID,
        eventHandler, numTasks);
  }
View Full Code Here
2308
2309
2310
2311
2312
2313
2314
2315
  @VisibleForTesting
  protected RootInputInitializerRunner createRootInputInitializerRunner(
      String dagName, String vertexName, TezVertexID vertexID,
      EventHandler eventHandler, int numTasks, int numNodes,
      Resource vertexTaskResource, Resource totalResource) {
    return new RootInputInitializerRunner(dagName, vertexName, vertexID,
        eventHandler, dagUgi, vertexTaskResource, totalResource, numTasks, numNodes);
  }
View Full Code Here
2452
2453
2454
2455
2456
2457
2458
2459
2460
  @VisibleForTesting
  protected RootInputInitializerRunner createRootInputInitializerRunner(
      String dagName, String vertexName, TezVertexID vertexID,
      EventHandler eventHandler, int numTasks, int numNodes,
      Resource vertexTaskResource, Resource totalResource) {
    return new RootInputInitializerRunner(dagName, vertexName, vertexID,
        eventHandler, dagUgi, vertexTaskResource, totalResource, numTasks, numNodes,
        appContext.getApplicationAttemptId().getAttemptId());
  }
View Full Code Here
TOP

Related Classes of org.apache.tez.dag.app.dag.RootInputInitializerRunner$InputInitializerCallback

  • com.google.common.util.concurrent.ThreadFactoryBuilder
  • org.apache.tez.dag.app.dag.event.VertexEventRootInputFailed
  • org.apache.tez.dag.app.dag.event.VertexEventRootInputInitialized
  • org.apache.tez.dag.app.dag.impl.TezRootInputInitializerContextImpl
  • org.apache.tez.dag.app.dag.impl.VertexImpl
  • org.apache.tez.runtime.api.TezRootInputInitializer
  • org.apache.tez.runtime.api.TezRootInputInitializerContext
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.