如何在Apache Spark SQL中綁定變量?例如: val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)
sqlContext.sql("SELECT * FROM src WHERE col1 = ${VAL1}").collect().foreach(println)
我使用下面的類來創建的Spark編碼器 Class OuterClass implements Serializable{
int id;
ArrayList<InnerClass> listofInner;
pubic int getId(){
return id;
}
public void setId (int num){
this.id = n