核心内容摘要
CoInitialize在线程中怎么调用?常见失败原因解析
问题需要使用其中一个df过滤另外一个dfpysparklegislators_combinedorgs.join(paths1[org_id],paths2[organization_id],frame2persons_memberships).drop_fields([organization_id])orgs和persons_memberships都是dynamic frame。
这里使用persons_memberships来筛选orgs的数据最后一步是删掉不想要的字段。
参考DynamicFrame class