Examples of removeIndex()


Examples of com.google.nigori.client.MigoriDatastore.removeIndex()

      RevValue f = store.put(index, "f".getBytes(), d);
      RevValue g = store.put(index, "g".getBytes(), e);
      Collection<RevValue> heads = store.get(index);
      assertThat(heads, hasItems(f, g));

      assertTrue(store.removeIndex(index, g.getRevision()));
    } finally {
      store.unregister();
    }
  }
}
View Full Code Here

Examples of com.google.nigori.client.MigoriDatastore.removeIndex()

      Collection<RevValue> heads = migori.get(index);
      assertEquals(1, heads.size());
      RevValue head = heads.toArray(new RevValue[1])[0];
      int total = Util.bin2int(head.getValue(), 0);
      assertEquals(REPEATS - 1, total);
      assertTrue(migori.removeIndex(index, head.getRevision()));

    } finally {
      assertTrue("Not unregistered", migori.unregister());
    }
  }
View Full Code Here

Examples of com.google.nigori.client.MigoriDatastore.removeIndex()

        total += value;
      }
      assertEquals(REPEATS * 10 - 4, total);
      assertNotNull(deleteAt);
      if (deleteAt != null)
        assertTrue(migori.removeIndex(index, deleteAt.getRevision()));

    } finally {
      assertTrue("Not unregistered", migori.unregister());
    }
  }
View Full Code Here

Examples of com.imaginea.mongodb.services.SystemCollectionService.removeIndex()

            @Override
            public Object execute() throws Exception {
                SystemCollectionService systemCollectionService = new SystemCollectionServiceImpl(connectionId);
                //The collection name is obtained by removing the DB name from the namespace.
                String collectionName = nameSpace.replace(dbName + ".", "");
                return systemCollectionService.removeIndex(dbName, collectionName, indexName);
            }
        });
        return response;

    }
View Full Code Here

Examples of com.imaginea.mongodb.services.impl.SystemCollectionServiceImpl.removeIndex()

            @Override
            public Object execute() throws Exception {
                SystemCollectionService systemCollectionService = new SystemCollectionServiceImpl(connectionId);
                //The collection name is obtained by removing the DB name from the namespace.
                String collectionName = nameSpace.replace(dbName + ".", "");
                return systemCollectionService.removeIndex(dbName, collectionName, indexName);
            }
        });
        return response;

    }
View Full Code Here

Examples of com.mobixess.jodb.core.index.JODBIndexingAgent.removeIndex()

                if (indexingRecords != null) {
                    for (int i = 0; i < indexingRecords.size(); i++) {
                        IndexingRecord record = indexingRecords.elementAt(i);
                        ByteBuffer currentValue = record.getPersistedDataBuffer();
                        JODBIndexingAgent indexingAgent = record.getIndexingAgent();
                        if (currentValue.limit() != 0 && !indexingAgent.removeIndex(offsetId, currentValue, null)) {
                            throw new JodbIOException("Illegal index state: can't remove index");
                        }
                        ByteBuffer pendingValue = record.getPendingDataBuffer();
                        if (pendingValue.limit() == 0) {
                            throw new JodbIOException(
View Full Code Here

Examples of com.nearinfinity.honeycomb.mysql.schema.TableSchema.removeIndex()

        final List<Delete> deletes = Lists.newArrayList();

        // Update the table schema to remove index schema details
        final TableSchema existingSchema = getSchema(tableId);
        final TableSchema updatedSchema = existingSchema.schemaCopy();
        updatedSchema.removeIndex(indexName);

        // Delete the old index
        deletes.add(generateIndexDelete(tableId, indexName));

        // Write the updated table schema
View Full Code Here

Examples of com.orientechnologies.orient.core.metadata.schema.OProperty.removeIndex()

    if (prop.getIndex() == null)
      throw new IllegalArgumentException("Property '" + cls + "." + field + "' has not index");

    final long indexedItems = prop.getIndex().getUnderlying().size();

    prop.removeIndex();

    return indexedItems;
  }
}
View Full Code Here

Examples of net.sf.katta.client.DeployClient.removeIndex()

  protected static void removeIndex(InteractionProtocol protocol, final String indexName) {
    IDeployClient deployClient = new DeployClient(protocol);
    if (!deployClient.existsIndex(indexName)) {
      throw new IllegalArgumentException("index '" + indexName + "' does not exist");
    }
    deployClient.removeIndex(indexName);
  }

  protected static void validateMinArguments(String[] args, int minCount) {
    if (args.length < minCount) {
      throw new IllegalArgumentException("not enough arguments");
View Full Code Here

Examples of net.sf.katta.client.DeployClient.removeIndex()

  @Test
  public void testCleanupOfClientWatchesOnUndeploy_KATTA_182() throws Exception {
    IDeployClient deployClient = new DeployClient(_miniCluster.getProtocol());
    IndexMetaData indexMD = deployClient.getIndexMetaData(INDEX1);
    deployClient.removeIndex(INDEX1);
    TestUtil.waitUntilShardsUndeployed(_protocol, indexMD);

    Client client = _client.getClient();
    assertThat(client.getIndices()).excludes((Object) INDEX_1);
    Map<String, Set<Watcher>> existWatches = getExistsWatches(client);
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.