List of seekToFirst() Examples

Examples of seekToFirst()

org.fusesource.leveldbjni.internal.JniKeyDBIterator.seekToFirst()
org.iq80.leveldb.DBIterator.seekToFirst()
Repositions the iterator so is is at the beginning of the Database.
org.rocksdb.RocksIterator.seekToFirst()
Position at the first key in the source. The iterator is Valid() after this call iff the source is not empty.

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

                        throws ReceiverThrowableType, IOException
                    {
                        DBIterator iterator = db.iterator();
                        try
                        {
                            for( iterator.seekToFirst(); iterator.hasNext(); iterator.next() )
                            {
                                byte[] state = iterator.peekNext().getValue();
                                String jsonState = new String( state, charset );
                                receiver.receive( new StringReader( jsonState ) );
                            }

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

      DBIterator it = db.iterator(new ReadOptions().fillCache(false));
      boolean destroyDatabase = false;


      if (configuration.clearThreshold() <= 0) {
         try {
            for (it.seekToFirst(); it.hasNext();) {
               Map.Entry<byte[], byte[]> entry = it.next();
               db.delete(entry.getKey());
               count++;


               if (count > configuration.clearThreshold()) {

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

      final TaskContext taskContext = new TaskContextImpl();


      List<Map.Entry<byte[], byte[]>> entries = new ArrayList<Map.Entry<byte[], byte[]>>(batchSize);
      DBIterator it = db.iterator(new ReadOptions().fillCache(false));
      try {
         for (it.seekToFirst(); it.hasNext();) {
            Map.Entry<byte[], byte[]> entry = it.next();
            entries.add(entry);
            if (entries.size() == batchSize) {
               final List<Map.Entry<byte[], byte[]>> batch = entries;
               entries = new ArrayList<Map.Entry<byte[], byte[]>>(batchSize);

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

         List<Long> times = new ArrayList<Long>();
         List<Object> keys = new ArrayList<Object>();
         DBIterator it = expiredDb.iterator(new ReadOptions().fillCache(false));
         long now = ctx.getTimeService().wallClockTime();
         try {
            for (it.seekToFirst(); it.hasNext();) {
               Map.Entry<byte[], byte[]> entry = it.next();


               Long time = (Long) unmarshall(entry.getKey());
               if (time > now)
                  break;

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

    DBIterator it = db.iterator(new ReadOptions().fillCache(false));
    boolean destroyDatabase = false;


    if (config.getClearThreshold() <= 0) {
      try {
        for (it.seekToFirst(); it.hasNext();) {
          Map.Entry<byte[], byte[]> entry = it.next();
          db.delete(entry.getKey());
          count++;


          if (count > config.clearThreshold) {

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

      throws CacheLoaderException {
    Set<InternalCacheEntry> entries = new HashSet<InternalCacheEntry>();


    DBIterator it = db.iterator(new ReadOptions().fillCache(false));
    try {
      for (it.seekToFirst(); it.hasNext();) {
        Map.Entry<byte[], byte[]> entry = it.next();
        entries.add(unmarshall(entry));
      }
    } catch (Exception e) {
      throw new CacheLoaderException(e);

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()


    Set<InternalCacheEntry> entries = new HashSet<InternalCacheEntry>();


    DBIterator it = db.iterator(new ReadOptions().fillCache(false));
    try {
      it.seekToFirst();
      for (int i = 0; it.hasNext() && i < maxEntries; i++) {
        Map.Entry<byte[], byte[]> entry = it.next();
        entries.add(unmarshall(entry));
      }
    } catch (Exception e) {

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

      throws CacheLoaderException {
    Set<Object> keys = new HashSet<Object>();


    DBIterator it = db.iterator(new ReadOptions().fillCache(false));
    try {
      for (it.seekToFirst(); it.hasNext();) {
        Map.Entry<byte[], byte[]> entry = it.next();
        Object key = unmarshall(entry.getKey());
        if (keysToExclude == null || keysToExclude.isEmpty()
            || !keysToExclude.contains(key))
          keys.add(key);

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

  protected void toStreamLockSafe(ObjectOutput oos)
      throws CacheLoaderException {
    DBIterator it = db.iterator(new ReadOptions().fillCache(false));
    try {


      for (it.seekToFirst(); it.hasNext();) {
        Map.Entry<byte[], byte[]> entry = it.next();
        InternalCacheEntry ice = unmarshall(entry);
        getMarshaller().objectToObjectStream(ice, oos);
      }
      getMarshaller().objectToObjectStream(null, oos);

View Full Code Here

Examples of org.iq80.leveldb.DBIterator.seekToFirst()

      List<Long> times = new ArrayList<Long>();
      List<Object> keys = new ArrayList<Object>();
      DBIterator it = expiredDb.iterator(new ReadOptions()
          .fillCache(false));
      try {
        for (it.seekToFirst(); it.hasNext();) {
          Map.Entry<byte[], byte[]> entry = it.next();


          Long time = (Long) unmarshall(entry.getKey());
          if (time > System.currentTimeMillis())
            break;

View Full Code Here

0 1 2 3

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.