public static void createTestData()
{
String clusterName = "TestCluster";
String host = "localhost:9171";
Cluster cluster = HFactory.getOrCreateCluster(clusterName, host);
Keyspace keyspace = HFactory.createKeyspace("beautifulKeyspaceName", cluster);
assertNotNull(keyspace);
String keyspaceName = "presto_database";
String columnFamilyName = "presto_test";
List<ColumnFamilyDefinition> columnFamilyDefinitions = createColumnFamilyDefinitions(keyspaceName, columnFamilyName);
KeyspaceDefinition keyspaceDefinition = HFactory.createKeyspaceDefinition(
keyspaceName,
StrategyModel.SIMPLE_STRATEGY.value(),
1,
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++) {