List of addKeyspace() Examples

Examples of addKeyspace()

com.hmsonline.virgil.CassandraStorage.addKeyspace()
com.netflix.astyanax.Cluster.addKeyspace()
Add a new keyspace to the cluster. The keyspace object may include column families as well. Create a KeyspaceDefinition object by calling makeKeyspaceDefinition(). @param def @return
me.prettyprint.cassandra.service.ThriftCluster.addKeyspace()
me.prettyprint.hector.api.Cluster.addKeyspace()

Examples of com.netflix.astyanax.Cluster.addKeyspace()

                        .setStrategyClass("SimpleStrategy")
                        .addColumnFamily(
                                cluster.makeColumnFamilyDefinition()
                                        .setName(CF_DATA.getName())
                                        .setComparatorType("UTF8Type"));
                cluster.addKeyspace(ksDef);
                Thread.sleep(1000);
            } catch (ConnectionException e) {
                LOG.error(e.getMessage());
            }
        }

View Full Code Here

Examples of com.netflix.astyanax.Cluster.addKeyspace()

                                cluster.makeColumnFamilyDefinition()
                                        .setName(CF_INDEX.getName())
                                        .setComparatorType(
                                                "CompositeType(LongType, LongType)")
                                        .setDefaultValidationClass("BytesType"));
                cluster.addKeyspace(ksDef);
                Thread.sleep(2000);
                populateKeyspace();
            } catch (ConnectionException e) {
                LOG.error(e.getMessage());
            }

View Full Code Here

Examples of me.prettyprint.cassandra.service.ThriftCluster.addKeyspace()


        KeyspaceDefinition keyspaceDef = cluster.describeKeyspace(cassandraKeyspace);
        if (keyspaceDef == null) {
            log.warn("Keyspace \" {} \" does not exist, creating it!", cassandraKeyspace);
            keyspaceDef = new ThriftKsDef(cassandraKeyspace);
            cluster.addKeyspace(keyspaceDef, true);


            addColumnFamily(cluster, USER_CF, 0);
            addColumnFamily(cluster, FRIENDS_CF, 0);
            addColumnFamily(cluster, FOLLOWERS_CF, 0);
            addColumnFamily(cluster, STATUS_CF, 0);

View Full Code Here

Examples of me.prettyprint.hector.api.Cluster.addKeyspace()


            KeyspaceDefinition keyspaceDefinition =
                    HFactory.createKeyspaceDefinition(Constants.KEYSPACE_NAME,
                                                      SimpleStrategy.class.getName(), 1, Arrays.asList(cfDef));


            cassandraCluster.addKeyspace(keyspaceDefinition);
        }


        Keyspace friendListKS = HFactory.createKeyspace(Constants.KEYSPACE_NAME, cassandraCluster);
        //cassandraCluster.getConnectionManager().shutdown(); // shutdown the connection  
        return friendListKS;

View Full Code Here

Examples of me.prettyprint.hector.api.Cluster.addKeyspace()

        Cluster cluster = getCluster(null);
        try {
            KeyspaceDefinition definition =
                    HFactory.createKeyspaceDefinition(keyspaceName.trim(), replicationStrategy, replicationFactor, null);
            if (isAdd) {
                cluster.addKeyspace(definition);
            } else {
                cluster.updateKeyspace(definition);
            }
        } catch (HectorException e) {
            throw new CassandraServerManagementException("Error " + (isAdd ? "adding" : "updating") + " a keyspace" +

View Full Code Here

Examples of me.prettyprint.hector.api.Cluster.addKeyspace()

                columnFamilyDefinitions);


        if (cluster.describeKeyspace(keyspaceName) != null) {
            cluster.dropKeyspace(keyspaceName, true);
        }
        cluster.addKeyspace(keyspaceDefinition, true);
        return HFactory.createKeyspace(keyspaceName, cluster);
    }


    public static void createTestData(String keyspaceName, String columnFamilyName)
    {

View Full Code Here

Examples of me.prettyprint.hector.api.Cluster.addKeyspace()

            
            KeyspaceDefinition keyspaceDefinition = 
                HFactory.createKeyspaceDefinition(DYN_KEYSPACE, "org.apache.cassandra.locator.SimpleStrategy", 
                    1, Arrays.asList(cfDefStandard, cfDefSuper));
                                               
            cluster.addKeyspace(keyspaceDefinition);
            
            // insert some data
            
            List<KeyspaceDefinition> keyspaces = cluster.describeKeyspaces();
            for (KeyspaceDefinition kd : keyspaces) {

View Full Code Here

Examples of me.prettyprint.hector.api.Cluster.addKeyspace()

                columnFamilyDefinitions);


        if (cluster.describeKeyspace(keyspaceName) != null) {
            cluster.dropKeyspace(keyspaceName, true);
        }
        cluster.addKeyspace(keyspaceDefinition, true);
        keyspace = HFactory.createKeyspace(keyspaceName, cluster);
        Mutator<String> mutator = HFactory.createMutator(keyspace, StringSerializer.get());


        long timestamp = System.currentTimeMillis();
        for (int rowNumber = 1; rowNumber < 10; rowNumber++) {

View Full Code Here

Examples of me.prettyprint.hector.api.Cluster.addKeyspace()

                columnFamilyDefinitions);


        if (cluster.describeKeyspace(keyspaceName) != null) {
            cluster.dropKeyspace(keyspaceName, true);
        }
        cluster.addKeyspace(keyspaceDefinition, true);
        keyspace = HFactory.createKeyspace(keyspaceName, cluster);
        Mutator<String> mutator = HFactory.createMutator(keyspace, StringSerializer.get());


        long timestamp = System.currentTimeMillis();
        for (int rowNumber = 1; rowNumber < 10; rowNumber++) {

View Full Code Here

Examples of me.prettyprint.hector.api.Cluster.addKeyspace()

                    keyspaceName, snapshotCFName, ComparatorType.COMPOSITETYPE);
            snapshotCFDef.setComparatorTypeAlias("(LongType, UTF8Type)");


            keyspaceDefinition = HFactory.createKeyspaceDefinition(
                    keyspaceName, ThriftKsDef.DEF_STRATEGY_CLASS, 1, Arrays.asList(cfDef, snapshotCFDef));
            cluster.addKeyspace(keyspaceDefinition, true);
        }
        keyspace = HFactory.createKeyspace(keyspaceName, cluster);


        eventTemplate = new ThriftColumnFamilyTemplate<String, Composite>(
                keyspace, eventCFName, StringSerializer.get(), CompositeSerializer.get());

View Full Code Here

0 1 2

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.