Spark-Cassandra-Connector 插入数据函数saveToCassandra【代码】

在spark-shell中将数据保存到cassandra：var data = normalfill.map(line => line.split("\u0005"))data.map(line => (line(0), line(1), line(2))) ).saveToCassandra("cui", "oper_ios",SomeColumns("user_no", "cust_id", "oper_code","oper_time") ) saveToCassandra方法 当字段类型是counter的时候，默认行为是计数 CREATE TABLE cui.incr( name text, count counter, PRIMARY KEY (name)) scala> var rdd = sc.paralleliz...