ApacheBeam错误信息“无匹配签名的运算符=',参数类型为DATE和INT64。支持的签名:ANY=ANY。”
创始人
2024-09-05 11:01:01
0

这个错误通常出现在尝试使用不同类型的数据进行匹配操作时。一种解决方法是将数据类型进行转换以匹配。例如,将DATE类型转换为INT64类型,或者将INT64类型转换为DATE类型。以下是一个示例,将DATE类型转换为INT64类型:

import apache_beam as beam
from apache_beam import typehints

class ConvertDateToInt(beam.DoFn):
    def process(self, element):
        date, value = element
        epoch = datetime.datetime(1970, 1, 1)
        date_int = int((date - epoch).total_seconds())
        return [(date_int, value)]

p = beam.Pipeline()

data = [
    (datetime.date(2021, 1, 1), 10),
    (datetime.date(2021, 1, 2), 20),
    (datetime.date(2021, 1, 3), 30)
]

input = p | beam.Create(data) 
output = input | beam.ParDo(ConvertDateToInt()) 

该示例将数据流中的DATE类型转换为INT64类型,并输出新的数据流。

相关内容

热门资讯

盘点一款!八闽福建辅助,购买的... 盘点一款!八闽福建辅助,购买的wpk辅助在哪里下载,技巧教程(讲解有挂);1、构建自己的微扑克辅助插...
科技揭秘!潮汕汇鱼虾蟹修改器,... 《科技揭秘!潮汕汇鱼虾蟹修改器,wepoker辅助脚本,可靠教程(有挂教程)》 潮汕汇鱼虾蟹修改器软...
我来向大家传授!皇豪互众插件,... 我来向大家传授!皇豪互众插件,aapoker透视脚本,专业教程(有挂方式);我来向大家传授!皇豪互众...
教学盘点!闽游辅助软件,佛手在... 您好,闽游辅助软件这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在这款...
热点推荐!四川途游麻将外挂,w... 热点推荐!四川途游麻将外挂,wepoker破解版内购,实用技巧(发现有挂);最新版2026是一款经典...
实测教程!九九联盟辅助神器,佛... 实测教程!九九联盟辅助神器,佛手在线有挂吗,详细教程(有挂方针);人气非常高,ai更新快且高清可以动...
玩家必看分享!微乐智能辅助软件... 玩家必看分享!微乐智能辅助软件是真的吗,wpk透视怎么安装,大神讲解(有挂教学);1、不需要AI权限...
重大通报!花花生活圈辅助工具安... 您好,花花生活圈辅助工具安装教程这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】...
大家学习交流!同城游辅助,ha... 大家学习交流!同城游辅助,hardrock透视工具,细节方法(有挂辅助);同城游辅助最新软件透明挂直...
分享个大家!上品游戏辅助器,大... 分享个大家!上品游戏辅助器,大菠萝789辅助器下载,必赢教程(的确有挂);上品游戏辅助器是一种具有地...