|
@@ -12,14 +12,19 @@ import org.apache.spark.rdd.RDD
|
|
|
import org.apache.spark.sql.types.DataTypes
|
|
|
import org.apache.spark.sql.{Dataset, Row, SparkSession}
|
|
|
|
|
|
+import java.time.LocalDateTime
|
|
|
+import java.time.format.DateTimeFormatter
|
|
|
import java.util
|
|
|
import scala.io.Source
|
|
|
|
|
|
object recsys_01_str_xgb_train {
|
|
|
def main(args: Array[String]): Unit = {
|
|
|
+
|
|
|
+ val dt = DateTimeFormatter.ofPattern("yyyyMMddHHmm").format(LocalDateTime.now())
|
|
|
+
|
|
|
val spark = SparkSession
|
|
|
.builder()
|
|
|
- .appName(this.getClass.getName)
|
|
|
+ .appName(this.getClass.getName + " : " + dt)
|
|
|
.getOrCreate()
|
|
|
val sc = spark.sparkContext
|
|
|
|