def METHOD_NAME():
    env: cy.CylonEnv = cy.CylonEnv(config=cy.MPIConfig(), distributed=True)
    print("CylonEnv Initialized: My rank: ", env.rank)
    inputFile1 = "data/input/cities_a_" + str(env.rank) + ".csv"
    inputFile2 = "data/input/cities_b_" + str(env.rank) + ".csv"
    intersectFile = "data/output/intersect_cities_" + str(env.rank) + ".csv"
    df1 = gcy.DataFrame.from_cudf(cudf.read_csv(inputFile1))
    df2 = gcy.DataFrame.from_cudf(cudf.read_csv(inputFile2))
    print("df1: \n", df1)
    print("df2: \n", df2)
    intersectDf = df1.set_intersect(other=df2, env=env)
    intersectDf.to_cudf().to_csv(intersectFile, index=False)
    print(env.rank, " written intersectFile to the file: ", intersectFile)
    env.finalize()