Examples of com.netflix.astyanax.Cluster.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

            Map<String, String> stratOptions = new HashMap<String, String>();
            stratOptions.put("replication_factor", "1");
            ksDef.setName(ks)
                    .setStrategyClass("SimpleStrategy")
                    .setStrategyOptions(stratOptions);
            cluster.addKeyspace(ksDef);
        }
        
        if (dropFirst){
            LOG.warn("Dropping {} column family.", cf);
            try{

View Full Code Here

                .setStrategyOptions(stratOptions)
                .addColumnFamily(
                        cluster.makeColumnFamilyDefinition().setName(cf).setComparatorType("UTF8Type")
                                .setKeyValidationClass("UTF8Type").setDefaultValidationClass("CounterColumnType"));


        cluster.addKeyspace(ksDef);
    }


}

View Full Code Here

        break;
      }
    }
    
    cluster.dropKeyspace(keyspaceName);
    OperationResult<SchemaChangeResult> result = cluster.addKeyspace(ourDef);
    
    columnFamilies.waitForNodesToBeUpToDate(result, 300000);
  }

View Full Code Here

        break;
      }
    }
    
    cluster.dropKeyspace(keyspaceName);
    OperationResult<SchemaChangeResult> result = cluster.addKeyspace(ourDef);
    
    columnFamilies.waitForNodesToBeUpToDate(result, 300000);
  }

View Full Code Here

        break;
      }
    }
    
    cluster.dropKeyspace(keyspaceName);
    String id = cluster.addKeyspace(ourDef);
    
    columnFamilies.waitForNodesToBeUpToDate(id, 300000);
  }

View Full Code Here

        break;
      }
    }
    
    cluster.dropKeyspace(keyspaceName);
    String id = cluster.addKeyspace(ourDef);
    
    columnFamilies.waitForNodesToBeUpToDate(id, 300000);
  }

View Full Code Here

        break;
      }
    }
    
    cluster.dropKeyspace(keyspaceName);
    OperationResult<SchemaChangeResult> result = cluster.addKeyspace(ourDef);
    
    columnFamilies.waitForNodesToBeUpToDate(result, 300000);
  }

View Full Code Here

        break;
      }
    }
    
    cluster.dropKeyspace(keyspaceName);
    OperationResult<SchemaChangeResult> result = cluster.addKeyspace(ourDef);
    
    columnFamilies.waitForNodesToBeUpToDate(result, 300000);
  }

View Full Code Here

        break;
      }
    }
    
    cluster.dropKeyspace(keyspaceName);
    String id = cluster.addKeyspace(ourDef);
    
    columnFamilies.waitForNodesToBeUpToDate(id, 300000);
  }

View Full Code Here

                        .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

0 1

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.