小编Zer*_*001的帖子

我正在尝试使用https://github.com/databricks/spark-avro读取 avro 文件，并且 avro 架构随着时间的推移而演变。我读了这样，mergeSchema 选项设置为true希望它会合并架构本身，但它不起作用。

sqlContext.read.format("com.databricks.spark.avro").option("mergeSchema", "true").load('s3://xxxx/d=2015-10-27/h=*/')

有什么工作？

我有两个这样的数据框

  student_rdf = (studentid, name, ...)
  student_result_rdf = (studentid, gpa, ...)

我们需要加入这两个数据框。我们现在正在这样做，

student_rdf.join(student_result_rdf, student_result_rdf["studentid"] == student_rdf["studentid"])

这样很简单。但是它会在工作节点之间创建大量数据改组，但是由于连接键是相似的，并且如果可以使用该键（studentid）对数据帧（理解partitionkey）进行分区，那么根本就不会进行改组。由于相似的数据将驻留在相似的节点中。可能吗？

当我从输入中读取数据帧时，我正在寻找一种基于列对数据进行分区的方法。并且如果Spark可能理解两个数据帧的两个partitionkey是相似的，那又如何呢？

我正在努力与cassandra和CQL.我正在定义这个表模式,

CREATE TABLE useradvisits (
  userid text,
  adid int,
  type int,
  timestamp timestamp,
  PRIMARY KEY (userid, adid, type)
 );

我想这样查询,

SELECT * from useradvisits where userid = 'user-1' and adId in (100, 1001);

但是它说,Bad Request:PRIMARY KEY部分adid不能被IN关系限制

我正在使用最新的datstax企业版3.1.

cqlsh控制台说,

[cqlsh 3.1.2 | Cassandra 1.2.6.1 | CQL spec 3.0.0 | Thrift protocol 19.36.0]

因为我需要(adId + type)是唯一的,即(100:1),(100:2)都存在于用户.任何人都可以帮我解决方法吗？

我想在用户离开页面时做一些事情，我添加了这段代码

window.onbeforunload = function (e){
   return "You save some unsaved data, Do you want to leave?";
}  

该提示可以通知用户，并且用户可以停留在页面上或离开。但是我想更多地了解他是否离开，并根据他的决定做事。我试过了

window.onbeforunload = function (e){
   var event = jQuery.Event(e);
   var result = confirm('want to leave?');
   if (result ==  false){
     //do sth.. 
     event.preventDefault();
   }else{
    //do clean up
   }
} 

但是失败了！它总是消失！

有人可以帮助我做到这一点吗？