承接SparkSql系列--需求01 点击打开链接
import java.text.SimpleDateFormat
import java.util import java.util.{Calendar, Date, Properties} import org.apache.spark.{SparkConf, SparkContext} import org.apache.spark.sql.types._ import org.apache.spark.sql.{DataFrame, Row, SQLContext, SparkSession} import org.slf4j.LoggerFactory /** * SaveMode.Append 如果表已经存在,则追加在该表中;若该表不存在,则会先创建表,再插入数据; * SaveMode.Overwrite 重写模式,其实质是先将已有的表及其数据全都删除,再重新创建该表,最后插入新的数据; * SaveMode.Ignore 若表不存在,则创建表,并存入数据;在表存在的情况下,直接跳过数据的存储,不会报错。 * 当前医院和日期(天)维度下,用户总数 *模板示例 **/ class AccountService {
val logger = LoggerFactory.getLogger(classOf[AccountService])
def
参考链接
发表评论