Datastax DSE Cassandra，Spark，Shark，Standalone Programm

2 回答

• 2

  All masters are unresponsive!
  

  意味着您尝试连接的IP实际上并不受spark限制 . 所以这基本上是一个网络配置错误 . 扫描以查看7077上正在侦听的接口，并确保连接到正确的接口 .

  至于第二个问题， where 运算符暗示你将对该子句进行谓词下推 . 目前，您无法使用主键执行此操作 . 如果你想在一个主键上 where 你可以做 filter 来完成它，但你不会看到很好的性能，因为这将进行整个表扫描 .

  回复于 2024-04-20T02:55:08+08:00
• 0

  到目前为止这是我的解决方案 . 这不是我所有问题的答案，但它适用于我，我想分享给你 .

  我使用hive jdbc驱动程序访问带有Java的SharkServer . 这个怎么运作：

  启动sharkserver： bin/dse shark --service sharkserver -p <port>

  Maven的依赖关系：

  <dependency>
      <groupId>org.apache.hive</groupId>
      <artifactId>hive-jdbc</artifactId>
      <version>0.13.1</version>
  </dependency>
  <dependency>
      <groupId>org.apache.hadoop</groupId>
      <artifactId>hadoop-core</artifactId>
      <version>0.20.2</version>
  </dependency>
  

  Java代码：

  import java.sql.Connection;
  import java.sql.DriverManager;
  import java.sql.ResultSet;
  import java.sql.SQLException;
  import java.sql.Statement;
  
  public class HiveJdbcClient {
    private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
  
    public static void main(String[] args) throws SQLException {
      try {
        Class.forName(driverName);
      } catch (ClassNotFoundException e) {
        e.printStackTrace();
        System.exit(1);
      }
      Connection con = DriverManager.getConnection("jdbc:hive://YOUR_IP:YOUR_PORT/default", "", "");
      Statement stmt = con.createStatement();
      String sql;
      ResultSet res;
  
  
  
      sql = "SELECT * FROM keyspace.colFam WHERE name = 'John'";
      res = stmt.executeQuery(sql);
      while (res.next()) {
          System.out.println(res.getString("name"));
     }
   }
  }
  

  回复于 2024-04-20T02:55:08+08:00