我的系统在virtualbox上安装了hadoop2.8.0、cassandra3.11.0和java。我想直接从javaapi连接到cassandra..我的cassandra服务器启动了cqlsh>正在工作..我已经编写了这个程序来连接到cassandra以在centos的vim编辑器中构建键空间。

import com.datastax.driver.core.Cluster;
 import com.datastax.driver.core.Host;  
 import com.datastax.driver.core.Metadata;
 import com.datastax.driver.core.Session;
 public class Cas
 {
 public static void main(String args[])
 {
  String query = "CREATE KEYSPACE tp WITH replication "
          + "= {'class':'SimpleStrategy', 'replication_factor':1};";

  Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
    Session session = cluster.connect();
     session.execute(query);
     session.execute("USE tp");
     System.out.println("Keyspace created");
  }

}
我是新的Cassandra和hadoop所以请指导我一些步骤来运行代码..任何帮助将不胜感激。。