* 12 * * * /data/data_for_sqc.sh 表示什么意思
时间: 2023-11-14 08:52:35 浏览: 195
这是一个 Linux 系统下的 Crontab 命令,用于定期执行 /data/data_for_sqc.sh 脚本文件。具体含义如下:
*:分钟(0-59)
12:小时(0-23)
*:日期(1-31)
*:月份(1-12)
*:星期(0-6,0 表示星期天)
因此,该命令表示在每天的 12 点执行 /data/data_for_sqc.sh 脚本文件。
相关问题
0 12 * * * /data/data_for_sqc.sh 表示什么意思
这个是一个 cron 表达式,表示在每天的 12 点整执行 /data/data_for_sqc.sh 这个脚本。具体含义如下:
- 第一列(0):表示分钟,取值范围为 0-59,这里为 0 表示每小时的 0 分钟执行。
- 第二列(12):表示小时,取值范围为 0-23,这里为 12 表示每天的 12 点执行。
- 第三列(*):表示日期,取值范围为 1-31,这里为 * 表示每天都执行。
- 第四列(*):表示月份,取值范围为 1-12,这里为 * 表示每个月都执行。
- 第五列(*):表示星期,取值范围为 0-6,0 表示星期天,这里为 * 表示每个星期都执行。
因此,这个 cron 表达式的含义是,在每天的 12 点整执行 /data/data_for_sqc.sh 脚本。
import spark.implicits._ FileRDD.toDS().show() val dftemp = FileRDD.toDF() val df = dftemp.registerTempTable("demo1") // val prop = new java.util.Properties // val sqlcommand = "select _1 as name,Round(avg(_2),2) as lowprice,Round(avg(_3),2) as minprice,Round(avg(_4),2) as topprice, _5 as times from demo1 group by _5,_1 order by times"; val sqlcommand = "select Round(avg(_2),2) as lowprice,Round(avg(_3),2) as minprice,Round(avg(_4),2) as topprice from demo1 group by _5,_1 order by _5"; // val sqlcommand = "select Round(avg(_2),2) as lowprice from demo1 group by _5,_1 order by _5"; val sel = sqc .sql(sqlcommand).show(10)
这段代码是在前面处理蔬菜价格数据的基础上,使用Spark SQL进行数据聚合和分析的示例,具体实现步骤如下:
1. 使用toDS方法将元组RDD转换为Dataset,并使用show方法输出处理后的数据。
2. 使用toDF方法将元组RDD转换为DataFrame,并使用registerTempTable方法注册为一个临时表。
3. 定义Spark SQL语句,使用SQLContext的sql方法执行SQL查询,并使用show方法输出查询结果。
4. 在SQL查询中使用聚合函数和分组语句,对蔬菜价格数据进行聚合和分析,并将结果按照一定的规则排序输出。
需要注意的是,这段代码中使用了Spark SQL对数据进行聚合和分析,可以方便地完成一些复杂的数据处理和分析任务,同时也需要熟悉Spark SQL的语法和使用方法。
阅读全文