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()

      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));
         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

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

    public void purge(DB aDatabase) {


        DBIterator iterator = aDatabase.iterator();


        try {
            iterator.seekToFirst();


            while (iterator.hasNext()) {
                Entry<byte[],byte[]> entry = iterator.next();


                aDatabase.delete(entry.getKey());

View Full Code Here

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

    private boolean requiresRepair() {
        boolean requiresRepair = false;


        DBIterator iterator = this.database().iterator();


        iterator.seekToFirst();


        if (iterator.hasNext()) {
            requiresRepair = true;


            Entry<byte[],byte[]> entry = iterator.next();

View Full Code Here

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

    public void purge() {


        DBIterator iterator = this.database().iterator();


        try {
            iterator.seekToFirst();


            while (iterator.hasNext()) {
                Entry<byte[],byte[]> entry = iterator.next();


                this.database().delete(entry.getKey());

View Full Code Here

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

        //   Would Snapshot make sense here?
        StorableKey key = null;
        try {
            DBIterator iter = _store.iterator();
            try {
                iter.seekToFirst();


                while (iter.hasNext()) {
                    Map.Entry<byte[], byte[]> entry = iter.next();
                    key = _storableKey(entry.getKey());
                    byte[] b = key.asBytes();

View Full Code Here

Examples of org.rocksdb.RocksIterator.seekToFirst()

      db.put("key1".getBytes(), "value1".getBytes());
      db.put("key2".getBytes(), "value2".getBytes());


      iterator = db.newIterator();


      iterator.seekToFirst();
      assertThat(iterator.isValid()).isTrue();
      assertThat(iterator.key()).isEqualTo("key1".getBytes());
      assertThat(iterator.value()).isEqualTo("value1".getBytes());
      iterator.next();
      assertThat(iterator.isValid()).isTrue();

View Full Code Here

Examples of org.rocksdb.RocksIterator.seekToFirst()

      iterator.seekToLast();
      iterator.prev();
      assertThat(iterator.isValid()).isTrue();
      assertThat(iterator.key()).isEqualTo("key1".getBytes());
      assertThat(iterator.value()).isEqualTo("value1".getBytes());
      iterator.seekToFirst();
      iterator.seekToLast();
      assertThat(iterator.isValid()).isTrue();
      assertThat(iterator.key()).isEqualTo("key2".getBytes());
      assertThat(iterator.value()).isEqualTo("value2".getBytes());
      iterator.status();

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.