code: def collect(self):
          
          local_df = self._schema_rdd.toPandas()
          correct_idx_df = _update_index_on_df(local_df, self._index_names)
          return correct_idx_df
docs: Collect the elements in an DataFrame
          and concatenate the partition.