def METHOD_NAME(
    benchmark,
    sample_df: DataFrame,
    mock_domain_retriever: DomainRetriever,
    mock_execute_pipeline: PipelineExecutor,
):
    step = JoinStep(
        name="join",
        right_pipeline=[{"name": "domain", "domain": "buzz"}],
        on=[
            ["NAME", "name"],
        ],
        type="left",
    )
    benchmark(execute_join, step, sample_df, mock_domain_retriever, mock_execute_pipeline)