我正在尝试替换所有具有“。”的字段。在字段名称中添加到“_”。
这就是我所拥有的:
def apply_renaming_mapping(df):
"""Given a dynamic data frame, if the field contains ., replace with _"""
# construct renaming mapping for ApplyMapping
mappings = list()
# for field in df.schema.fields:
for name, dtpye in df.dtypes:
if '.' in name:
mappings.append((name, dtype, name.replace('.', '_'), dtype))
# apply mapping
reanmed= ApplyMapping(frame=df, mappings=mappings)
return renamed
但我想我错过了一些作品。不断收到以下错误:在relationalize_and_write中重命名= apply_renaming_mapping(m_df.toDF()) File apply_renaming_mapping reanmed= ApplyMapping(frame=df, mappings=mappings) TypeError: ApplyMapping() takes no arguments 在处理上述异常期间,发生了另一个异常:回溯(最近一次通话最后):
我在这里做错了什么?