hadoop从java连接到cassandra

Question

我的系统在virtualbox上安装了hadoop 2.8.0、cassandra 3.11.0和java。我想直接从java API连接到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，所以请指导我运行代码的一些步骤。。任何帮助都将不胜感激