这是我的定义:
@Store(type="elasticsearch", hostname="localhost", username="elastic", password="changeme", port='9200', index.name = 'frauds', index.type='_doc')
define table FraudIndex (timestamp long, creditCardNo string, suspiciousTrader string, amount double, currency string);这是我的问题:
@info(name='SuspiciousTradeES')
from TradeStream as t join FraudTable as f
on t.creditCardNo == f.creditCardNo
select eventTimestamp() as timestamp, t.creditCardNo, t.trader as suspiciousTrader, t.amount as amount, t.currency as currency
insert into FraudIndex;不幸的是,Kibana无法识别和时间字段,因为它是一个“数字”。
我该如何得到可能的时间戳呢?
编辑:我还可以添加一个问题,我如何使用WSO2SI中的地图和geo_point类型?
发布于 2020-12-13 05:39:57
手动准备我的映射,它起作用了。
{
"properties": {
"timestamp": {
"type": "date",
"format": "yyyy-MM-dd HH:mm:ss"
},
"creditCardNo": {
"type": "keyword"
},
"suspiciousTrader": {
"type": "keyword"
},
"coordinates": {
"type": "geo_point"
},
"amount": {
"type": "double"
},
"currency": {
"type": "keyword"
}
}
} https://stackoverflow.com/questions/65167430
复制相似问题