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

Examples of org.apache.tez.dag.app.dag.event.VertexEventRootInputInitialized

3345
3346
3347
3348
3349
3350
3351
3352
3353
          new RuntimeException("MockInitializerFailed")));
      dispatcher.await();
    }

    public void completeInputInitialization() {
      eventHandler.handle(new VertexEventRootInputInitialized(vertexID, inputs.get(0)
          .getName(), null));
      dispatcher.await();
    }
View Full Code Here
3354
3355
3356
3357
3358
3359
3360
3361
3362
    public void completeInputDistribution(byte[] payload) {
      List<Event> events = Lists.newArrayListWithCapacity(1);
      InputUpdatePayloadEvent event = InputUpdatePayloadEvent.create(ByteBuffer.wrap(payload));
      events.add(event);
      eventHandler.handle(new VertexEventRootInputInitialized(vertexID, inputs
          .get(0).getName(), events));
      dispatcher.await();
    }
View Full Code Here
3371
3372
3373
3374
3375
3376
3377
3378
3379
      for (int i = 0; i < targetTasks; i++) {
        InputDataInformationEvent diEvent = InputDataInformationEvent.createWithSerializedPayload(i,
            null);
        events.add(diEvent);
      }
      eventHandler.handle(new VertexEventRootInputInitialized(vertexID, inputs
          .get(initializerIndex).getName(), events));
      dispatcher.await();
    }
View Full Code Here
200
201
202
203
204
205
206
207
    public void onSuccess(List<Event> result) {
      initializer.setComplete();
      LOG.info(
          "Succeeded InputInitializer for Input: " + initializer.getInput().getName() +
              " on vertex " + initializer.getVertexLogIdentifier());
      eventHandler.handle(new VertexEventRootInputInitialized(vertexID,
          initializer.getInput().getName(), result));
    }
View Full Code Here
177
178
179
180
181
182
183
184
    }

    @SuppressWarnings("unchecked")
    @Override
    public void onSuccess(List<Event> result) {
      eventHandler.handle(new VertexEventRootInputInitialized(vertexID,
          inputName, result));
    }
View Full Code Here
2269
2270
2271
2272
2273
2274
2275
2276
2277
      for (int i = 0; i < targetTasks; i++) {
        RootInputDataInformationEvent diEvent = new RootInputDataInformationEvent(
            i, null);
        events.add(diEvent);
      }
      eventHandler.handle(new VertexEventRootInputInitialized(vertexID, inputs
          .get(0).getEntityName(), events));
      dispatcher.await();
    }
View Full Code Here
1561
1562
1563
1564
1565
1566
1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
  public static class RootInputInitializedTransition implements
      MultipleArcTransition<VertexImpl, VertexEvent, VertexState> {

    @Override
    public VertexState transition(VertexImpl vertex, VertexEvent event) {
      VertexEventRootInputInitialized liInitEvent = (VertexEventRootInputInitialized) event;

      vertex.vertexManager.onRootVertexInitialized(
          liInitEvent.getInputName(),
          vertex.getAdditionalInputs().get(liInitEvent.getInputName())
              .getDescriptor(), liInitEvent.getEvents());

      vertex.numInitializedInputs++;
      if (vertex.numInitializedInputs == vertex.inputsWithInitializers.size()) {
        // All inputs initialized, shutdown the initializer.
        vertex.rootInputInitializer.shutdown();
View Full Code Here
150
151
152
153
154
155
156
157
    }

    @SuppressWarnings("unchecked")
    @Override
    public void onSuccess(List<Event> result) {
      eventHandler.handle(new VertexEventRootInputInitialized(vertexID,
          inputName, result));
    }
View Full Code Here
1421
1422
1423
1424
1425
1426
1427
1428
1429
1430
1431
1432
1433
1434
1435
1436
  public static class RootInputInitializedTransition implements
      MultipleArcTransition<VertexImpl, VertexEvent, VertexState> {

    @Override
    public VertexState transition(VertexImpl vertex, VertexEvent event) {
      VertexEventRootInputInitialized liInitEvent = (VertexEventRootInputInitialized) event;

      vertex.vertexScheduler.onRootVertexInitialized(
          liInitEvent.getInputName(),
          vertex.getAdditionalInputs().get(liInitEvent.getInputName())
              .getDescriptor(), liInitEvent.getEvents());

      vertex.numInitializedInputs++;
      if (vertex.numInitializedInputs == vertex.inputsWithInitializers.size()) {
        // All inputs initialized, shutdown the initializer.
        vertex.rootInputInitializer.shutdown();
View Full Code Here
1695
1696
1697
1698
1699
1700
1701
1702
1703
      for (int i = 0; i < targetTasks; i++) {
        RootInputDataInformationEvent diEvent = new RootInputDataInformationEvent(
            i, null);
        events.add(diEvent);
      }
      eventHandler.handle(new VertexEventRootInputInitialized(vertexID, inputs
          .get(0).getEntityName(), events));
      dispatcher.await();
    }
View Full Code Here
TOP

Related Classes of org.apache.tez.dag.app.dag.event.VertexEventRootInputInitialized

  • org.apache.tez.dag.app.dag.impl.TestVertexImpl$RootInputInitializerManagerControlled
  • org.apache.tez.dag.app.dag.impl.TestVertexImpl$RootInputInitializerRunnerControlled
  • org.apache.tez.dag.app.dag.impl.VertexImpl$RootInputInitializedTransition
  • org.apache.tez.dag.app.dag.RootInputInitializerManager$InputInitializerCallback
  • org.apache.tez.dag.app.dag.RootInputInitializerRunner$InputInitializerCallback
    • 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.