def METHOD_NAME(self, query_rdd, num_partitions, grid_type, index_type, expected_count):
    spatial_rdd = self.create_point_rdd(input_location, splitter, num_partitions)
    self.partition_rdds(query_rdd, spatial_rdd, grid_type)
    join_params = JoinParams(True, True, index_type, JoinBuildSide.LEFT)
    results = JoinQuery.spatialJoin(query_rdd, spatial_rdd, join_params).collect()
    self.sanity_check_flat_join_results(results)
    assert expected_count == results.__len__()