如果您使用的是pandas 1.2.0 或更新版本(2020 年 12 月 26 日发布),笛卡尔积(交叉关节)可以简化如下:
df = df1.merge(df2, how='cross') # simplified cross joint for pandas >= 1.2.0
另外,如果您担心系统性能(执行时间),建议使用list(map... 而不是较慢的apply(... axis=1)
使用apply(... axis=1):
%%timeit
df['overlap'] = df.apply(lambda x:
len(set(x['ColumnB1']).intersection(
set(x['ColumnB2']))), axis=1)
800 µs ± 59.1 µs per loop (mean ± std. dev. of 7 runs, 1000 loops each)
使用list(map(...时:
%%timeit
df['overlap'] = list(map(lambda x, y: len(set(x).intersection(set(y))), df['ColumnB1'], df['ColumnB2']))
217 µs ± 25.5 µs per loop (mean ± std. dev. of 7 runs, 1000 loops each)
请注意,使用list(map... 的速度提高了 3 倍!
整套代码供你参考:
data = {'ColumnA1': ['id1', 'id2'], 'ColumnB1': [['a', 'b', 'c'], ['a', 'd', 'e']]}
df1 = pd.DataFrame(data)
data = {'ColumnA2': ['id3', 'id4'], 'ColumnB2': [['a','b','c','x','y', 'z'], ['d','e','f','p','q', 'r']]}
df2 = pd.DataFrame(data)
df = df1.merge(df2, how='cross') # for pandas version >= 1.2.0
df['overlap'] = list(map(lambda x, y: len(set(x).intersection(set(y))), df['ColumnB1'], df['ColumnB2']))
df = df[df['overlap'] >= 2]
print (df)