List of rangeLookup() Examples

Examples of rangeLookup()

org.xtreemfs.babudb.api.database.Database.rangeLookup()
org.xtreemfs.babudb.index.LSMTree.rangeLookup()
Performs a range lookup. Key-value paris are returned in an iterator in ascending key order, where only such keys are returned between from (inclusively) and to (inclusively), according to the comparator. @param from the first key (inclusively) @param to the last key (exclusively) @return an iterator with key-value pairs
org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

            // look up a range of elements
            byte[] from = "e".getBytes();
            byte[] to = "f".getBytes();
            
            Iterator<Entry<byte[], byte[]>> mapIt = map.subMap(from, to).entrySet().iterator();
            Iterator<Entry<byte[], byte[]>> indexIt = diskIndex.rangeLookup(from, to, true);
            
            while (indexIt.hasNext() || mapIt.hasNext()) {
                
                Entry<byte[], byte[]> next = indexIt.next();
                String indexKey = new String(next.getKey());

View Full Code Here

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

            // look up another range of elements
            byte[] from = "fd".getBytes();
            byte[] to = "sa".getBytes();
            
            Iterator<Entry<byte[], byte[]>> mapIt = map.subMap(from, to).entrySet().iterator();
            Iterator<Entry<byte[], byte[]>> indexIt = diskIndex.rangeLookup(from, to, true);
            
            while (indexIt.hasNext() || mapIt.hasNext()) {
                
                Entry<byte[], byte[]> next = indexIt.next();
                String indexKey = new String(next.getKey());

View Full Code Here

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

            MMAPED);
        
        {
            // look up the complete list of elements
            Iterator<Entry<byte[], byte[]>> mapIt = map.descendingMap().entrySet().iterator();
            Iterator<Entry<byte[], byte[]>> indexIt = diskIndex.rangeLookup(null, null, false);
            
            while (indexIt.hasNext() || mapIt.hasNext()) {
                
                Entry<byte[], byte[]> next = indexIt.next();
                String indexKey = new String(next.getKey());

View Full Code Here

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

            byte[] from = "e".getBytes();
            byte[] to = "f".getBytes();
            
            Iterator<Entry<byte[], byte[]>> mapIt = map.descendingMap().subMap(to, from).entrySet()
                    .iterator();
            Iterator<Entry<byte[], byte[]>> indexIt = diskIndex.rangeLookup(from, to, false);
            
            while (mapIt.hasNext())
                System.out.println(new String(mapIt.next().getKey()));
            
            System.out.println(" --------- ");

View Full Code Here

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

            byte[] from = "fd".getBytes();
            byte[] to = "sa".getBytes();
            
            Iterator<Entry<byte[], byte[]>> mapIt = map.descendingMap().subMap(to, from).entrySet()
                    .iterator();
            Iterator<Entry<byte[], byte[]>> indexIt = diskIndex.rangeLookup(from, to, false);
            
            while (indexIt.hasNext() || mapIt.hasNext()) {
                
                Entry<byte[], byte[]> next = indexIt.next();
                String indexKey = new String(next.getKey());

View Full Code Here

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

              index.writeIndex(DataGenerator.randomIterator(lookupHits, size, hitrate, minStrLen, maxStrLen, minChar, maxChar));
            }
        } else {
          //   populate the lookup-hits table
          DiskIndex diskIndexTmp = new DiskIndex(path, new DefaultByteRangeComparator(), compress, mmap);
          Iterator<Entry<byte[], byte[]>> itTmp = diskIndexTmp.rangeLookup(null, null, true);
          while(itTmp.hasNext()) {
                if(generator.nextInt() % hitrate == 0)
                  lookupHits.add(itTmp.next().getKey());
          }
          diskIndexTmp.destroy();

View Full Code Here

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

        
        while(warmups-- > 0) {
          int readEntries = 10000;          
          //   read the disk index
          DiskIndex diskIndex = new DiskIndex(path, new DefaultByteRangeComparator(), compress, mmap);
          Iterator<Entry<byte[], byte[]>> it = diskIndex.rangeLookup(null, null, true);
          while(it.hasNext() && readEntries-- > 0) it.next();
          diskIndex.destroy();
        }


      // clear caches...

View Full Code Here

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

      // run garbage collection to remove any existing mmap:ed pages
      Runtime.getRuntime().gc();
      
      //   read the disk index
      DiskIndex diskIndex = new DiskIndex(path, new DefaultByteRangeComparator(), compress, mmap);
      Iterator<Entry<byte[], byte[]>> it = diskIndex.rangeLookup(null, null, true);
    
      /* iterate over all data in the disk index to measure the prefix lookup throughput */
      long iterStart = System.currentTimeMillis();
      while(it.hasNext()) it.next();
      long iterTime = System.currentTimeMillis() - iterStart;

View Full Code Here

Examples of org.xtreemfs.babudb.index.reader.DiskIndex.rangeLookup()

          int firstIndex = Math.abs(generator.nextInt()) % lookupHits.size();
          
          from = lookupHits.get(firstIndex);
          to = lookupHits.get(firstIndex + (Math.abs(generator.nextInt()) % (lookupHits.size() - firstIndex)));
          
            Iterator<Entry<byte[], byte[]>> tmpIt = diskIndex.rangeLookup(from, to, true);
            
            /* iterate over all data returned by the range scan */
            long scanStart = System.currentTimeMillis();
            while(tmpIt.hasNext()) tmpIt.next();
            scanTotal += System.currentTimeMillis() - scanStart;

View Full Code Here

0 1 2 3 4

TOP

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.