Package eu.stratosphere.nephele.executiongraph

Examples of eu.stratosphere.nephele.executiongraph.ExecutionVertexID


  public void read(DataInput in) throws IOException {

    // Read the jobID
    boolean isNotNull = in.readBoolean();
    if (isNotNull) {
      this.vertexID = new ExecutionVertexID();
      this.vertexID.read(in);
    }

    // Read the return code
    this.returnCode = EnumUtils.readEnum(in, ReturnCode.class);
View Full Code Here


    // Make sure all tasks are fully registered before they are started
    for (final TaskDeploymentDescriptor tdd : tasks) {

      final JobID jobID = tdd.getJobID();
      final ExecutionVertexID vertexID = tdd.getVertexID();
      RuntimeEnvironment re;

      // retrieve the registered cache files from job configuration and create the local tmp file.
      Map<String, FutureTask<Path>> cpTasks = new HashMap<String, FutureTask<Path>>();
      for (Entry<String, String> e: DistributedCache.getCachedFile(tdd.getJobConfiguration())) {
View Full Code Here

   * Default constructor for serialization/deserialization.
   */
  public TaskDeploymentDescriptor() {

    this.jobID = new JobID();
    this.vertexID = new ExecutionVertexID();
    this.taskName = null;
    this.indexInSubtaskGroup = 0;
    this.currentNumberOfSubtasks = 0;
    this.jobConfiguration = new Configuration();
    this.taskConfiguration = new Configuration();
View Full Code Here

    isNotNull = in.readBoolean();

    // Read the execution vertex ID
    if (isNotNull) {
      this.executionVertexID = new ExecutionVertexID();
      this.executionVertexID.read(in);
    } else {
      this.executionVertexID = null;
    }
View Full Code Here

  private int channelCapacityExhaustedCounter;

  public InternalOutputGateProfilingData() {
    this.jobId = new JobID();
    this.executionVertexID = new ExecutionVertexID();
    this.gateIndex = 0;
    this.profilingInternval = 0;
    this.channelCapacityExhaustedCounter = 0;
  }
View Full Code Here

  private int noRecordsAvailableCounter;

  public InternalInputGateProfilingData() {
    this.jobId = new JobID();
    this.executionVertexID = new ExecutionVertexID();
    this.gateIndex = 0;
    this.profilingInternval = 0;
    this.noRecordsAvailableCounter = 0;
  }
View Full Code Here

  private final JobID jobId;

  public InternalExecutionVertexProfilingData() {
    this.jobId = new JobID();
    this.executionVertexID = new ExecutionVertexID();
  }
View Full Code Here

   */
  @Test
  public void testConstructorWithValidArguments() {

    final JobID jobID = new JobID();
    final ExecutionVertexID vertexID = new ExecutionVertexID();
    final String taskName = "task name";
    final int indexInSubtaskGroup = 0;
    final int currentNumberOfSubtasks = 1;
    final Configuration jobConfiguration = new Configuration();
    final Configuration taskConfiguration = new Configuration();
View Full Code Here

   */
  @Test
  public void testConstructorWithInvalidArguments() {

    final JobID jobID = new JobID();
    final ExecutionVertexID vertexID = new ExecutionVertexID();
    final String taskName = "task name";
    final int indexInSubtaskGroup = 0;
    final int currentNumberOfSubtasks = 1;
    final Configuration jobConfiguration = new Configuration();
    final Configuration taskConfiguration = new Configuration();
View Full Code Here

   */
  @Test
  public void testSerialization() {

    final JobID jobID = new JobID();
    final ExecutionVertexID vertexID = new ExecutionVertexID();
    final String taskName = "task name";
    final int indexInSubtaskGroup = 0;
    final int currentNumberOfSubtasks = 1;
    final Configuration jobConfiguration = new Configuration();
    final Configuration taskConfiguration = new Configuration();
View Full Code Here

TOP

Related Classes of eu.stratosphere.nephele.executiongraph.ExecutionVertexID

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.