我有如下資料:
val jsonData = "{\n \"id\":\"" a "\",\n \"Category\":\"Flink\",\n \"eventTime\":\"" dateTime "\"\n \n}"
我還創建了一個DateTime變數來獲取current timestamp.
val dateTime:String =DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS").format(LocalDateTime.now)
現在我有一個用于創建資料集的 for 回圈:
for (a <- minRange to maxRange) {
jsonData = "{\n \"id\":\"" a "\",\n \"Category\":\"Flink\",\n \"eventTime\":\"" dateTime "\"\n \n}"
println(jsonData)
Thread.sleep(500)
}
現在我想要實作的是,我想動態替換資料中的eventTime屬性值JSON。這是event time記錄的。記錄到達源的時間。但是,當我嘗試運行示例代碼時,它給了我如下輸出:
{
"id":"10",
"Category":"Flink",
"eventTime":"2021-12-26 21:09:53.217"
}
{
"id":"11",
"Category":"Flink",
"eventTime":"2021-12-26 21:09:53.217"
}
正如我們所看到的,它在代碼運行時給了我時間戳,這是正確的,但是否可以像"eventTime":"2021-12-26 21:09:55.589",那樣動態獲取它"eventTime":"2021-12-26 21:09:58.800"?
uj5u.com熱心網友回復:
dateTime用它的值替換變數應該為您獲取動態event time.
for (a <- minRange to maxRange) {
jsonData = "{\n \"id\":\"" a "\",\n \"Category\":\"Flink\",\n \"eventTime\":\"" DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS").format(LocalDateTime.now) "\"\n \n}"
println(jsonData)
Thread.sleep(500)
}
輸出:
{
"id":"0",
"Category":"Flink",
"eventTime":"2021-12-26 23:03:04.609"
}
{
"id":"1",
"Category":"Flink",
"eventTime":"2021-12-26 23:03:05.114"
}
{
"id":"2",
"Category":"Flink",
"eventTime":"2021-12-26 23:03:05.616"
}
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/394690.html
標籤:斯卡拉
