Package eu.stratosphere.nephele.executiongraph

Examples of eu.stratosphere.nephele.executiongraph.ExecutionGroupVertexIterator$TraversalEntry


    return this.executionGraph;
  }

  public boolean instanceAllocatedByJob(InternalInstanceProfilingData instanceProfilingData) {

    final ExecutionGroupVertexIterator it = new ExecutionGroupVertexIterator(this.executionGraph, true,
      this.executionGraph.getIndexOfCurrentExecutionStage());
    while (it.hasNext()) {

      final ExecutionGroupVertex groupVertex = it.next();
      for (int i = 0; i < groupVertex.getCurrentNumberOfGroupMembers(); i++) {
        final ExecutionVertex executionVertex = groupVertex.getGroupMember(i);
        if (instanceProfilingData.getInstanceConnectionInfo().equals(
          executionVertex.getAllocatedResource().getInstance().getInstanceConnectionInfo())) {
          this.collectedInstanceProfilingData.put(instanceProfilingData.getInstanceConnectionInfo(),
View Full Code Here


  public InstanceSummaryProfilingEvent getInstanceSummaryProfilingData(long timestamp) {

    final Set<AbstractInstance> tempSet = new HashSet<AbstractInstance>();
    // First determine the number of allocated instances in the current stage
    final ExecutionGroupVertexIterator it = new ExecutionGroupVertexIterator(this.executionGraph, true,
      this.executionGraph.getIndexOfCurrentExecutionStage());
    while (it.hasNext()) {

      final ExecutionGroupVertex groupVertex = it.next();
      for (int i = 0; i < groupVertex.getCurrentNumberOfGroupMembers(); i++) {
        final ExecutionVertex executionVertex = groupVertex.getGroupMember(i);
        final AbstractInstance instance = executionVertex.getAllocatedResource().getInstance();
        if(!(instance instanceof DummyInstance)) {
          tempSet.add(instance);
View Full Code Here

   * @param executionGraph
   *        the job to be registered
   */
  public void registerJob(final ExecutionGraph executionGraph) {

    final Iterator<ExecutionGroupVertex> it = new ExecutionGroupVertexIterator(executionGraph, true, -1);
    while (it.hasNext()) {

      final ExecutionGroupVertex groupVertex = it.next();
      final InputSplit[] inputSplits = groupVertex.getInputSplits();

      if (inputSplits == null) {
        continue;
      }
View Full Code Here

   * @param executionGraph
   *        the job to be unregistered
   */
  public void unregisterJob(final ExecutionGraph executionGraph) {

    final Iterator<ExecutionGroupVertex> it = new ExecutionGroupVertexIterator(executionGraph, true, -1);
    while (it.hasNext()) {

      final ExecutionGroupVertex groupVertex = it.next();
      final InputSplit[] inputSplits = groupVertex.getInputSplits();

      if (inputSplits == null) {
        continue;
      }
View Full Code Here

   * @param eg
   *        the execution graph of the job to be registered
   */
  void registerJob(final ExecutionGraph eg) {

    final Iterator<ExecutionGroupVertex> it = new ExecutionGroupVertexIterator(eg, true, -1);
    while (it.hasNext()) {

      final ExecutionGroupVertex groupVertex = it.next();
      final InputSplit[] inputSplits = groupVertex.getInputSplits();

      if (inputSplits == null) {
        continue;
      }
View Full Code Here

          for (final AllocatedResource allocatedResource : allocatedResources) {

            AllocatedResource resourceToBeReplaced = null;
            // Important: only look for instances to be replaced in the current stage
            final Iterator<ExecutionGroupVertex> groupIterator = new ExecutionGroupVertexIterator(eg, true,
              stage.getStageNumber());
            while (groupIterator.hasNext()) {

              final ExecutionGroupVertex groupVertex = groupIterator.next();
              for (int i = 0; i < groupVertex.getCurrentNumberOfGroupMembers(); ++i) {

                final ExecutionVertex vertex = groupVertex.getGroupMember(i);

                if (vertex.getExecutionState() == ExecutionState.SCHEDULED
View Full Code Here

TOP

Related Classes of eu.stratosphere.nephele.executiongraph.ExecutionGroupVertexIterator$TraversalEntry

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.