Package eu.stratosphere.pact.runtime.test.util

Examples of eu.stratosphere.pact.runtime.test.util.RandomIntPairGenerator.reset()


    }
    while (sorter.write(record) && num < 3354624);
//    System.out.println("WRITE TIME " + (System.currentTimeMillis() - startTime));
   
    // re-read the records
    generator.reset();
    IntPair readTarget = new IntPair();
   
//    startTime = System.currentTimeMillis();
    int i = 0;
    while (i < num) {
View Full Code Here


      num++;
    }
    while (sorter.write(record));
   
    // re-read the records
    generator.reset();
   
    MutableObjectIterator<IntPair> iter = sorter.getIterator();
    IntPair readTarget = new IntPair();
    int count = 0;
   
View Full Code Here

    while (sorter.write(record) && num < 3354624);
   
    sorter.reset();
   
    // write a second sequence of records. since the values are of fixed length, we must be able to write an equal number
    generator.reset();
   
    // write the buffer full with the first set of records
    int num2 = -1;
    do {
      generator.next(record);
View Full Code Here

    while (sorter.write(record) && num2 < 3354624);
   
    Assert.assertEquals("The number of records written after the reset was not the same as before.", num, num2);
   
    // re-read the records
    generator.reset();
    IntPair readTarget = new IntPair();
   
    int i = 0;
    while (i < num) {
      generator.next(record);
View Full Code Here

    while (start < end) {
      sorter.swap(start++, end--);
    }
   
    // re-read the records
    generator.reset();
    IntPair readTarget = new IntPair();
   
    int i = num - 1;
    while (i >= 0) {
      generator.next(record);
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. 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.