流数据handler防御性处理

在DolphinDB database流数据订阅时，我在Stream handler中,针对partition value做防御性处理：

def fixNullDate(mutable TB,mutable msg)
{
    if(msg.Date.hasNull()){
        msg[`Date] = msg.Date.nullFill(today())
    }
    data = select * from msg
    TB.append!(data)
}

这样是否可行，还是有不一样高效的写法？

0 条评论
分类：技术问答

默认排序时间排序

1 个回答

Jason Tang - 时序数据库技术支持 2021-05-11 12:14

可以去掉data = select * from msg，减少复制一份数据

def fixNullDate(mutable TB,mutable msg)
{
    if(msg.Date.hasNull()){
        msg[`Date] = msg.Date.nullFill(today())
    }
    TB.append!(msg)
}

流数据handler防御性处理

1 个回答

相似问题