def METHOD_NAME():
    env: cy.CylonEnv = cy.CylonEnv(config=cy.MPIConfig(), distributed=True)
    print("CylonContext Initialized: My rank: ", env.rank)
    # read the same parquet file schema by all workers
    input_file = "data/parquet/part_0000.parquet"
    schema = pq.read_schema(input_file)
    # get the schema of the first worker and broadcast it to all other workers
    buf = None
    bcast_root = 0
    if env.rank == bcast_root:
        buf = schema.serialize()
    buf = bcast_buffer(buf, bcast_root, env.context)
    # deserialize the schema
    with pyarrow.ipc.open_stream(buf) as reader:
        received_schema = reader.schema
    assert schema.equals(received_schema), \
        f'Broadcasted schema and the original schema are not the same. Worker rank: {[env.rank]}'