Package org.apache.hadoop.util

Examples of org.apache.hadoop.util.QuickSort.sort()

104
105
106
107
108
109
110
111
112
113
114
    }
  }

  public void sort() {
    QuickSort quickSort = new QuickSort();
    quickSort.sort(this, 0, size());
  }

  public static void main(String[] args) throws Exception {
    try {
      System.out.println("SequenceIDBuffer");
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
      return;
    }
    // quick sort the offsets
    OffsetSortable sortableObj = new OffsetSortable(memBlock, kvbuffer);
    QuickSort quickSort = new QuickSort();
    quickSort.sort(sortableObj, 0, memBlock.currentPtr);
  }

  protected void sortIndividualMemoryBlock(List<MemoryBlock> memBlks) {
    if (memBlks == null) {
      return;
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
  @Override
  protected RecordIterator doWork() {
    StackedComparator r = new StackedComparator(defs);
    QuickSort qs = new QuickSort();
    qs.sort(r, 0, records.size());
    return new OrderIterator();
  }

  public class SortDefinition {
    boolean forward;
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
  }
 
  @Override
  public void sort(SelectionVector4 vector4, VectorContainer container){
    QuickSort qs = new QuickSort();
    qs.sort(this, 0, vector4.getTotalCount());
  }

  @Override
  public void swap(int sv0, int sv1) {
    int tmp = vector4.get(sv0);
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
 
  public long doSort(){
    QuickSort qs = new QuickSort();
    ByteSortable b = new ByteSortable();
    long nano = System.nanoTime();
    qs.sort(b, 0, RECORD_COUNT);
    return System.nanoTime() - nano;
  }
 
  private class ByteSortable implements IndexedSortable{
    final byte[] space = new byte[RECORD_SIZE];
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
  @Override
  public void sort(SelectionVector4 vector4, VectorContainer container){
    Stopwatch watch = new Stopwatch();
    watch.start();
    QuickSort qs = new QuickSort();
    qs.sort(this, 0, vector4.getTotalCount());
    logger.debug("Took {} us to sort {} records", watch.elapsed(TimeUnit.MICROSECONDS), vector4.getTotalCount());
  }

  @Override
  public void swap(int sv0, int sv1) {
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
  }
 
  @Override
  public void sort(SelectionVector2 vector2, VectorContainer container){
    QuickSort qs = new QuickSort();
    qs.sort(this, 0, vector2.getCount());
  }

  @Override
  public void swap(int sv0, int sv1) {
    char tmp = vector2.getIndex(sv0);
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
  public void sort(SelectionVector2 vector2){
    QuickSort qs = new QuickSort();
    Stopwatch watch = new Stopwatch();
    watch.start();
    if (vector2.getCount() > 0) {
      qs.sort(this, 0, vector2.getCount());
    }
    logger.debug("Took {} us to sort {} records", watch.elapsed(TimeUnit.MICROSECONDS), vector2.getCount());
  }

  @Override
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
  @Override
  public void sort(SelectionVector4 vector4, VectorContainer container){
    Stopwatch watch = new Stopwatch();
    watch.start();
    QuickSort qs = new QuickSort();
    qs.sort(this, 0, vector4.getTotalCount());
    logger.debug("Took {} us to sort {} records", watch.elapsed(TimeUnit.MICROSECONDS), vector4.getTotalCount());
  }

  @Override
  public void swap(int sv0, int sv1) {
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
  }

  @Override
  public void sort(SelectionVector2 vector2, VectorContainer container){
    QuickSort qs = new QuickSort();
    qs.sort(this, 0, vector2.getCount());
  }

  @Override
  public void swap(int sv0, int sv1) {
    char tmp = vector2.getIndex(sv0);
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.