java spark hive 例子代码
时间: 2023-02-28 21:55:46 浏览: 128
以下是 Java 代码,实现对 Spark 数据源中的数据进行查询并将结果存入 Hive 表:
```
import org.apache.spark.sql.SparkSession;
public class SparkHiveExample {
public static void main(String[] args) {
SparkSession spark = SparkSession
.builder()
.appName("SparkHiveExample")
.config("spark.sql.warehouse.dir", "/user/hive/warehouse")
.enableHiveSupport()
.getOrCreate();
spark.sql("SELECT * FROM sample_table").show();
spark.stop();
}
}
```
需要注意的是,在运行这段代码之前,需要确保 Hive 已经启动,并且已经创建了名为 `sample_table` 的表。
阅读全文